c9562ddb82Adds the node:vfs builtin module with VirtualFileSystem and provider classes. No integration with fs, modules, or SEA. Assisted-by: Claude-Opus4.7 Signed-off-by: Matteo Collina <hello@matteocollina.com> PR-URL: https://github.com/nodejs/node/pull/63115 Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Paolo Insogna <paolo@cowtech.it> Reviewed-By: Robert Nagy <ronagy@icloud.com> Reviewed-By: Stephen Belanger <admin@stephenbelanger.com>
75 lines
2 KiB
JavaScript
75 lines
2 KiB
JavaScript
// Flags: --experimental-vfs
|
|
'use strict';
|
|
|
|
// Tests for VFS watch() on a single file: change detection, listener
|
|
// registration, ref/unref, and the watch-then-create flow.
|
|
|
|
const common = require('../common');
|
|
const assert = require('assert');
|
|
const { once } = require('events');
|
|
const vfs = require('node:vfs');
|
|
|
|
(async () => {
|
|
// Listener as 2nd argument
|
|
{
|
|
const myVfs = vfs.create();
|
|
myVfs.writeFileSync('/lf.txt', 'a');
|
|
const w = myVfs.watch('/lf.txt', common.mustNotCall());
|
|
w.close();
|
|
}
|
|
|
|
// Listener add/remove + ref/unref smoke
|
|
{
|
|
const myVfs = vfs.create();
|
|
myVfs.writeFileSync('/r.txt', 'a');
|
|
const w = myVfs.watch('/r.txt');
|
|
const fn = common.mustNotCall();
|
|
w.on('change', fn);
|
|
w.removeListener('change', fn);
|
|
w.on('change', fn);
|
|
w.removeAllListeners('change');
|
|
w.ref();
|
|
w.unref();
|
|
w.close();
|
|
}
|
|
|
|
// Double close is a no-op
|
|
{
|
|
const myVfs = vfs.create();
|
|
myVfs.writeFileSync('/x.txt', 'a');
|
|
const watcher = myVfs.watch('/x.txt');
|
|
watcher.close();
|
|
watcher.close();
|
|
}
|
|
|
|
// persistent: false reaches the unref branch
|
|
{
|
|
const myVfs = vfs.create();
|
|
myVfs.writeFileSync('/p.txt', 'a');
|
|
const watcher = myVfs.watch('/p.txt', { persistent: false });
|
|
watcher.close();
|
|
}
|
|
|
|
// Watching a missing path then creating it
|
|
{
|
|
const myVfs = vfs.create();
|
|
const watcher = myVfs.watch('/late.txt', { interval: 25 });
|
|
const changed = once(watcher, 'change');
|
|
myVfs.writeFileSync('/late.txt', 'now');
|
|
await changed;
|
|
watcher.close();
|
|
}
|
|
|
|
// Modifying the watched file emits change with the basename as filename
|
|
{
|
|
const myVfs = vfs.create();
|
|
myVfs.writeFileSync('/single.txt', 'a');
|
|
const watcher = myVfs.watch('/single.txt', { interval: 25 });
|
|
const evt = once(watcher, 'change');
|
|
myVfs.writeFileSync('/single.txt', 'longer-content-changed');
|
|
const [eventType, filename] = await evt;
|
|
assert.strictEqual(eventType, 'change');
|
|
assert.strictEqual(filename, 'single.txt');
|
|
watcher.close();
|
|
}
|
|
})().then(common.mustCall());
|