node/test/parallel/test-vfs-fs-promises.js at 819ceed6a56ec1f52224cea4c37a655ba1b1ef80 · nodejs/node · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
// Flags: --experimental-vfs
'use strict';

// fs/promises dispatches through VFS for each supported path-based and
// FileHandle-based operation.

const common = require('../common');
const assert = require('assert');
const fs = require('fs');
const fsp = require('fs/promises');
const path = require('path');
const vfs = require('node:vfs');

(async () => {
  const mountPoint = path.resolve('/tmp/vfs-promises-' + process.pid);
  const myVfs = vfs.create();
  myVfs.mkdirSync('/src', { recursive: true });
  myVfs.writeFileSync('/src/hello.txt', 'hello world');
  myVfs.mount(mountPoint);
  const p = (s) => path.join(mountPoint, s);

  // Path-based reads
  assert.strictEqual((await fsp.stat(p('src/hello.txt'))).isFile(), true);
  assert.strictEqual((await fsp.lstat(p('src/hello.txt'))).isFile(), true);
  assert.ok((await fsp.readdir(p('src'))).includes('hello.txt'));
  assert.strictEqual(await fsp.readFile(p('src/hello.txt'), 'utf8'),
                     'hello world');
  assert.strictEqual(await fsp.realpath(p('src/hello.txt')),
                     p('src/hello.txt'));
  await fsp.access(p('src/hello.txt'));

  // statfs
  const sfs = await fsp.statfs(p('src/hello.txt'));
  assert.strictEqual(typeof sfs.bsize, 'number');

  // Path-based writes
  await fsp.writeFile(p('src/pw.txt'), 'pdata');
  assert.strictEqual(fs.readFileSync(p('src/pw.txt'), 'utf8'), 'pdata');
  await fsp.appendFile(p('src/pw.txt'), ' more');
  assert.strictEqual(fs.readFileSync(p('src/pw.txt'), 'utf8'), 'pdata more');

  assert.strictEqual(await fsp.mkdir(p('src/pd')), undefined);
  await fsp.rmdir(p('src/pd'));
  // Recursive mkdir reports the first created directory below the mount point.
  assert.strictEqual(await fsp.mkdir(p('src/pr/sub'), { recursive: true }),
                     p('src/pr'));
  await fsp.rm(p('src/pw.txt'));
  assert.strictEqual(fs.existsSync(p('src/pw.txt')), false);

  await fsp.copyFile(p('src/hello.txt'), p('src/pcopy.txt'));
  assert.strictEqual(fs.readFileSync(p('src/pcopy.txt'), 'utf8'),
                     'hello world');

  await fsp.rename(p('src/pcopy.txt'), p('src/prenamed.txt'));
  assert.strictEqual(fs.existsSync(p('src/pcopy.txt')), false);
  await fsp.unlink(p('src/prenamed.txt'));

  await fsp.symlink('hello.txt', p('src/plnk.txt'));
  assert.strictEqual(await fsp.readlink(p('src/plnk.txt')), 'hello.txt');

  await fsp.truncate(p('src/hello.txt'), 5);
  assert.strictEqual(fs.readFileSync(p('src/hello.txt'), 'utf8'), 'hello');

  await fsp.link(p('src/hello.txt'), p('src/plink.txt'));
  assert.strictEqual(fs.readFileSync(p('src/plink.txt'), 'utf8'), 'hello');

  const tmp = await fsp.mkdtemp(p('src/ptmp-'));
  assert.ok(tmp.startsWith(p('src/ptmp-')));
  assert.strictEqual(fs.statSync(tmp).isDirectory(), true);

  // Attribute mutations
  const uid = process.getuid?.() ?? 0;
  const gid = process.getgid?.() ?? 0;
  const now = new Date();
  await fsp.chmod(p('src/hello.txt'), 0o644);
  await fsp.chown(p('src/hello.txt'), uid, gid);
  await fsp.lchown(p('src/hello.txt'), uid, gid);
  await fsp.utimes(p('src/hello.txt'), now, now);
  await fsp.lutimes(p('src/hello.txt'), now, now);

  await fsp.lchmod(p('src/plnk.txt'), 0o700);
  assert.strictEqual(
    (await fsp.lstat(p('src/hello.txt'))).mode & 0o777,
    0o644,
  );
  assert.strictEqual(
    (await fsp.lstat(p('src/plnk.txt'))).mode & 0o777,
    0o700,
  );

  // FileHandle via fsp.open
  const handle = await fsp.open(p('src/hello.txt'), 'r');
  assert.strictEqual(await handle.readFile('utf8'), 'hello');
  await handle.close();

  myVfs.unmount();
})().then(common.mustCall());