beenull/ente
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

unlink directory listener for watcher

Browse source
This commit is contained in:
Rushikesh Tote 2022-06-07 16:50:57 +05:30
parent 8ab2de6fb7
commit 4725407d14
1 changed files with 19 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
src/utils/watch.ts
View file

@ -79,7 +79,6 @@ export function initWatcher(mainWindow: BrowserWindow) {
});
const watcher = chokidar.watch(folderPaths, {
depth: 1,
awaitWriteFinish: true,
});
watcher
@ -92,6 +91,9 @@ export function initWatcher(mainWindow: BrowserWindow) {
.on('unlink', (path) => {
mainWindow.webContents.send('watch-unlink', path);
})
.on('unlinkDir', (path) => {
mainWindow.webContents.send('watch-unlink', path, true);
})
.on('error', (error) => {
logError(error, 'error while watching files');
});
@ -102,7 +104,11 @@ export function initWatcher(mainWindow: BrowserWindow) {
export function registerWatcherFunctions(
WatchServiceInstance: any,
add: (WatchServiceInstance: any, path: string) => Promise<void>,
remove: (WatchServiceInstance: any, path: string) => Promise<void>
remove: (
WatchServiceInstance: any,
path: string,
isDir?: boolean
) => Promise<void>
) {
ipcRenderer.removeAllListeners('watch-add');
ipcRenderer.removeAllListeners('watch-change');
@ -116,8 +122,15 @@ export function registerWatcherFunctions(
await remove(WatchServiceInstance, filePath);
await add(WatchServiceInstance, filePath);
});
ipcRenderer.on('watch-unlink', async (_, filePath: string) => {
filePath = filePath.split(path.sep).join(path.posix.sep);
await remove(WatchServiceInstance, filePath);
});
ipcRenderer.on(
'watch-unlink',
async (_, filePath: string, isDir?: boolean) => {
filePath = filePath.split(path.sep).join(path.posix.sep);
if (isDir) {
await remove(WatchServiceInstance, filePath, true);
} else {
await remove(WatchServiceInstance, filePath);
}
}
);
}