|
| 1 | +'use strict'; |
| 2 | + |
| 3 | +const common = require('../common'); |
| 4 | +const tmpdir = require('../common/tmpdir'); |
| 5 | +const assert = require('assert'); |
| 6 | +const path = require('path'); |
| 7 | +const fs = require('fs'); |
| 8 | +const URL = require('url').URL; |
| 9 | + |
| 10 | +tmpdir.refresh(); |
| 11 | + |
| 12 | +let fileCounter = 1; |
| 13 | +const nextFile = () => path.join(tmpdir.path, `file${fileCounter++}`); |
| 14 | + |
| 15 | +const generateStringPath = (file, suffix = '') => file + suffix; |
| 16 | + |
| 17 | +const generateURLPath = (file, suffix = '') => |
| 18 | + new URL('file://' + path.resolve(file) + suffix); |
| 19 | + |
| 20 | +const generateUint8ArrayPath = (file, suffix = '') => |
| 21 | + new Uint8Array(Buffer.from(file + suffix)); |
| 22 | + |
| 23 | +const generatePaths = (file, suffix = '') => [ |
| 24 | + generateStringPath(file, suffix), |
| 25 | + generateURLPath(file, suffix), |
| 26 | + generateUint8ArrayPath(file, suffix), |
| 27 | +]; |
| 28 | + |
| 29 | +const generateNewPaths = (suffix = '') => [ |
| 30 | + generateStringPath(nextFile(), suffix), |
| 31 | + generateURLPath(nextFile(), suffix), |
| 32 | + generateUint8ArrayPath(nextFile(), suffix), |
| 33 | +]; |
| 34 | + |
| 35 | +function checkSyncFn(syncFn, p, args, fail) { |
| 36 | + const result = fail ? 'must fail' : 'must succeed'; |
| 37 | + const failMsg = `failed testing sync ${p} ${syncFn.name} ${result}`; |
| 38 | + if (!fail) { |
| 39 | + try { |
| 40 | + syncFn(p, ...args); |
| 41 | + } catch (e) { |
| 42 | + console.log(failMsg, e); |
| 43 | + throw e; |
| 44 | + } |
| 45 | + } else { |
| 46 | + assert.throws(() => syncFn(p, ...args), { |
| 47 | + code: 'EISDIR', |
| 48 | + name: 'Error', |
| 49 | + }, failMsg); |
| 50 | + } |
| 51 | +} |
| 52 | + |
| 53 | +function checkAsyncFn(asyncFn, p, args, fail) { |
| 54 | + const result = fail ? 'must fail' : 'must succeed'; |
| 55 | + const failMsg = `failed testing async ${p} ${asyncFn.name} ${result}`; |
| 56 | + if (!fail) { |
| 57 | + try { |
| 58 | + asyncFn(p, ...args, common.mustCall()); |
| 59 | + } catch (e) { |
| 60 | + console.log(failMsg, e); |
| 61 | + throw e; |
| 62 | + } |
| 63 | + } else { |
| 64 | + assert.throws( |
| 65 | + () => asyncFn(p, ...args, common.mustNotCall()), { |
| 66 | + code: 'EISDIR', |
| 67 | + name: 'Error', |
| 68 | + }, |
| 69 | + failMsg |
| 70 | + ); |
| 71 | + } |
| 72 | +} |
| 73 | + |
| 74 | +function checkPromiseFn(promiseFn, p, args, fail) { |
| 75 | + const result = fail ? 'must fail' : 'must succeed'; |
| 76 | + const failMsg = `failed testing promise ${p} ${promiseFn.name} ${result}`; |
| 77 | + if (!fail) { |
| 78 | + const r = promiseFn(p, ...args).catch((err) => { |
| 79 | + console.log(failMsg, err); |
| 80 | + throw err; |
| 81 | + }); |
| 82 | + if (r && r.close) r.close(); |
| 83 | + } else { |
| 84 | + assert.rejects( |
| 85 | + () => promiseFn(p, ...args), { |
| 86 | + code: 'EISDIR', |
| 87 | + name: 'Error', |
| 88 | + }, |
| 89 | + failMsg |
| 90 | + ); |
| 91 | + } |
| 92 | +} |
| 93 | + |
| 94 | +function check(asyncFn, syncFn, promiseFn, |
| 95 | + { suffix, fail, args = [] }) { |
| 96 | + const file = nextFile(); |
| 97 | + fs.writeFile(file, 'data', (e) => { |
| 98 | + assert.ifError(e); |
| 99 | + const paths = generatePaths(file, suffix); |
| 100 | + for (const p of paths) { |
| 101 | + if (asyncFn) checkAsyncFn(asyncFn, p, args, fail); |
| 102 | + if (promiseFn) checkPromiseFn(promiseFn, p, args, fail); |
| 103 | + if (syncFn) checkSyncFn(syncFn, p, args, fail); |
| 104 | + } |
| 105 | + }); |
| 106 | +} |
| 107 | + |
| 108 | +function checkManyToMany(asyncFn, syncFn, promiseFn, |
| 109 | + { suffix, fail, args = [] }) { |
| 110 | + const source = nextFile(); |
| 111 | + fs.writeFile(source, 'data', (err) => { |
| 112 | + assert.ifError(err); |
| 113 | + if (asyncFn) { |
| 114 | + generateNewPaths(suffix) |
| 115 | + .forEach((p) => checkAsyncFn(asyncFn, source, [p, ...args], fail)); |
| 116 | + } |
| 117 | + if (promiseFn) { |
| 118 | + generateNewPaths(suffix) |
| 119 | + .forEach((p) => checkPromiseFn(promiseFn, source, [p, ...args], fail)); |
| 120 | + } |
| 121 | + if (syncFn) { |
| 122 | + generateNewPaths(suffix) |
| 123 | + .forEach((p) => checkSyncFn(syncFn, source, [p, ...args], fail)); |
| 124 | + } |
| 125 | + }); |
| 126 | +} |
| 127 | + |
| 128 | +check(fs.readFile, fs.readFileSync, fs.promises.readFile, |
| 129 | + { suffix: '', fail: false }); |
| 130 | +check(fs.readFile, fs.readFileSync, fs.promises.readFile, |
| 131 | + { suffix: '/', fail: true }); |
| 132 | +check(fs.writeFile, fs.writeFileSync, fs.promises.writeFile, |
| 133 | + { suffix: '', fail: false, args: ['data'] }); |
| 134 | +check(fs.writeFile, fs.writeFileSync, fs.promises.writeFile, |
| 135 | + { suffix: '/', fail: true, args: ['data'] }); |
| 136 | +check(fs.appendFile, fs.appendFileSync, fs.promises.appendFile, |
| 137 | + { suffix: '', fail: false, args: ['data'] }); |
| 138 | +check(fs.appendFile, fs.appendFileSync, fs.promises.appendFile, |
| 139 | + { suffix: '/', fail: true, args: ['data'] }); |
| 140 | +check(undefined, fs.createReadStream, undefined, |
| 141 | + { suffix: '', fail: false }); |
| 142 | +check(undefined, fs.createReadStream, undefined, |
| 143 | + { suffix: '/', fail: true }); |
| 144 | +check(undefined, fs.createWriteStream, undefined, |
| 145 | + { suffix: '', fail: false }); |
| 146 | +check(undefined, fs.createWriteStream, undefined, |
| 147 | + { suffix: '/', fail: true }); |
| 148 | +check(fs.truncate, fs.truncateSync, fs.promises.truncate, |
| 149 | + { suffix: '', fail: false, args: [42] }); |
| 150 | +check(fs.truncate, fs.truncateSync, fs.promises.truncate, |
| 151 | + { suffix: '/', fail: true, args: [42] }); |
| 152 | + |
| 153 | +check(fs.open, fs.openSync, fs.promises.open, { suffix: '', fail: false }); |
| 154 | +check(fs.open, fs.openSync, fs.promises.open, { suffix: '/', fail: true }); |
| 155 | + |
| 156 | +checkManyToMany(fs.copyFile, fs.copyFileSync, fs.promises.copyFile, |
| 157 | + { suffix: '', fail: false }); |
| 158 | +checkManyToMany(fs.copyFile, fs.copyFileSync, fs.promises.copyFile, |
| 159 | + { suffix: '/', fail: true }); |
0 commit comments