-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathindex.js
84 lines (80 loc) · 1.96 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
"use strict";
const fs = require("fs");
const path = require("path");
const result = [];
let running = 1;
const recursiveFind = (dir, keyword, cb) => {
fs.readdir(dir, "utf-8", (err, files) => {
if (err) {
return cb(err);
}
files.forEach((file, index) => {
fs.lstat(path.join(dir, file), (err, stats) => {
if (err) {
return cb(err);
}
if (stats.isDirectory()) {
running++;
process.nextTick(() =>
recursiveFind(path.join(dir, file), keyword, cb)
);
if (index === files.length - 1) {
running--;
}
} else {
fs.readFile(path.join(dir, file), "utf-8", (err, data) => {
if (err) {
return cb(err);
}
if (data.includes(keyword)) {
result.push(path.join(dir, file));
}
if (index === files.length - 1) {
running--;
}
if (index === files.length - 1 && running === 0) {
return cb(null, result);
}
});
}
});
});
});
};
const fsPromisified = require("fs/promises");
const promisifiedRecursiveFind = async (dir, keyword, cb) => {
try {
const result = await recursive(dir, keyword);
return cb(null, result.flat(Infinity).filter(Boolean));
} catch (err) {
return cb(err);
}
};
const recursive = async (dir, keyword) => {
try {
const files = await fsPromisified.readdir(dir, "utf-8");
return Promise.all(
files.map((file) => recursive(path.join(dir, file), keyword))
);
} catch (err) {
if (err.code === "ENOTDIR") {
const content = await fsPromisified.readFile(dir, "utf-8");
if (content.includes(keyword)) {
return dir;
}
} else {
throw err;
}
}
};
promisifiedRecursiveFind(
"../",
"Batman",
(err, data) => {
if (err) {
console.log(err);
} else {
console.log(data);
}
}
);