init

马宇豪

2024-07-16 f591c27b57e2418c9495bc02ae8cfff84d35bc18

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
/*
    MIT License http://www.opensource.org/licenses/mit-license.php
    Author Tobias Koppers @sokra
*/
"use strict";
 
const path = require("path");
const DirectoryWatcher = require("./DirectoryWatcher");
 
class WatcherManager {
    constructor(options) {
        this.options = options;
        this.directoryWatchers = new Map();
    }
 
    getDirectoryWatcher(directory) {
        const watcher = this.directoryWatchers.get(directory);
        if (watcher === undefined) {
            const newWatcher = new DirectoryWatcher(this, directory, this.options);
            this.directoryWatchers.set(directory, newWatcher);
            newWatcher.on("closed", () => {
                this.directoryWatchers.delete(directory);
            });
            return newWatcher;
        }
        return watcher;
    }
 
    watchFile(p, startTime) {
        const directory = path.dirname(p);
        if (directory === p) return null;
        return this.getDirectoryWatcher(directory).watch(p, startTime);
    }
 
    watchDirectory(directory, startTime) {
        return this.getDirectoryWatcher(directory).watch(directory, startTime);
    }
}
 
const watcherManagers = new WeakMap();
/**
 * @param {object} options options
 * @returns {WatcherManager} the watcher manager
 */
module.exports = options => {
    const watcherManager = watcherManagers.get(options);
    if (watcherManager !== undefined) return watcherManager;
    const newWatcherManager = new WatcherManager(options);
    watcherManagers.set(options, newWatcherManager);
    return newWatcherManager;
};
module.exports.WatcherManager = WatcherManager;