-
Notifications
You must be signed in to change notification settings - Fork 1
/
index.js
98 lines (77 loc) · 1.77 KB
/
index.js
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
'use strict';
const fs = require('fs');
const path = require('path');
const { promisify } = require('util');
const { rimraf } = require('rimraf');
const cpr = promisify(require('cpr'));
const lstat = promisify(fs.lstat);
const readdir = promisify(fs.readdir);
const rmdir = promisify(fs.rmdir);
async function move(src, dest, options = {}, callback) {
if (typeof options === 'function') {
callback = options;
options = {};
}
try {
let {
overwrite,
merge,
purge,
filter = () => true
} = options;
if (!await Promise.resolve(filter(src, dest))) {
return;
}
let destStats;
try {
destStats = await lstat(dest);
} catch (err) {}
if (destStats && !overwrite && !merge) {
throw new Error('Destination directory already exists');
}
let srcStats = await lstat(src);
let areBothDirs = destStats && srcStats.isDirectory() && destStats.isDirectory();
// pre
if (overwrite && (!areBothDirs || !merge)) {
await rimraf(dest);
destStats = null;
}
// during
if (!destStats) {
try {
await promisify(fs.rename)(src, dest);
} catch (err) {
if (err.code === 'EXDEV') {
await cpr(src, dest);
await rimraf(src);
}
}
}
if (merge && areBothDirs) {
for (let file of await readdir(src)) {
await move(
path.join(src, file),
path.join(dest, file),
options
);
}
}
// post
if (purge) {
await rimraf(src);
} else {
try {
await rmdir(src);
} catch (err) {}
}
if (callback) {
callback(null);
}
} catch (err) {
if (!callback) {
throw err;
}
callback(err);
}
}
module.exports = move;