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
98
99
100
101
102
|
/*---
includes: [compareArray.js, compatFs.js]
flags: [async]
---*/
var dname = `${test_dir}/`;
var fname = (d) => d + '/fs_promises_06_file';
var fname_utf8 = (d) => d + '/fs_promises_αβγ_06';
let stages = [];
var testSync = () => new Promise((resolve, reject) => {
try {
try { fs.unlinkSync(fname(dname)); } catch (e) {}
try { fs.unlinkSync(fname_utf8(dname)); } catch (e) {}
fs.writeFileSync(fname(dname), fname(dname));
fs.renameSync(fname(dname), fname_utf8(dname));
fs.accessSync(fname_utf8(dname));
try {
fs.renameSync(fname_utf8(dname), dname);
} catch (e) {
if (e.syscall != 'rename'
|| (e.code != 'ENOTDIR' && e.code != 'EISDIR'))
{
reject(new Error('fs.unlinkSync error 1'));
}
}
stages.push("renameSync");
resolve();
} catch (e) {
reject(e);
}
});
var testCallback = () => new Promise((resolve, reject) => {
try {
try { fs.unlinkSync(fname(dname)); } catch (e) {}
try { fs.unlinkSync(fname_utf8(dname)); } catch (e) {}
fs.writeFileSync(fname(dname), fname(dname));
fs.rename(fname(dname), fname_utf8(dname), err => {
if (err) {
reject(new Error('fs.unlink error 1'));
}
fs.accessSync(fname_utf8(dname));
fs.rename(fname_utf8(dname), dname, err => {
if (err.syscall != 'rename'
|| (err.code != 'ENOTDIR' && err.code != 'EISDIR'))
{
reject(new Error('fs.unlink error 2'));
}
});
stages.push("rename");
resolve();
});
} catch (e) {
reject(e);
}
});
let testFsp = () => Promise.resolve()
.then(() => {
try { fs.unlinkSync(fname(dname)); } catch (e) {}
try { fs.unlinkSync(fname_utf8(dname)); } catch (e) {}
fs.writeFileSync(fname(dname), fname(dname));
})
.then(() => fsp.rename(fname(dname), fname_utf8(dname)))
.then(() => fsp.access(fname_utf8(dname)))
.then(() => fsp.rename(fname_utf8(dname), dname))
.catch(e => {
if (e.syscall != 'rename'
|| (e.code != 'ENOTDIR' && e.code != 'EISDIR'))
{
throw new Error('fsp.rename error 1');
}
})
.then(() => {
stages.push("fsp.rename");
})
let p = Promise.resolve()
.then(testSync)
.then(testCallback)
.then(testFsp)
.then(() => assert.compareArray(stages, ["renameSync", "rename", "fsp.rename"]))
p.then($DONE, $DONE);
|
