starred/yaak-mountain-loop
1
0
Fork 0
mirror of https://github.com/mountain-loop/yaak.git synced 2026-03-21 17:09:09 +01:00
Code Issues 8 Packages Projects Releases 10 Wiki Activity

Don't notify twice

Browse Source
This commit is contained in:
Gregory Schier
2024-09-09 15:44:35 -07:00
parent 36890b9a32
commit 7907dcc220
2 changed files with 26 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
plugin-runtime/src/index.worker.ts
View File

@@ -14,7 +14,7 @@ import { HttpRequestActionPlugin } from '@yaakapp/api/lib/plugins/HttpRequestAct
import { TemplateFunctionPlugin } from '@yaakapp/api/lib/plugins/TemplateFunctionPlugin';
import interceptStdout from 'intercept-stdout';
import * as console from 'node:console';
import { readFileSync, watch } from 'node:fs';
import { Stats, readFileSync, statSync, watch } from 'node:fs';
import path from 'node:path';
import * as util from 'node:util';
import { parentPort, workerData } from 'node:worker_threads';
@@ -100,8 +100,9 @@ async function initialize() {
await reloadModule();
return sendPayload({ type: 'reload_response' }, null);
};
watch(path.join(pathMod), cb);
watch(path.join(pathPkg), cb);
watchFile(pathMod, cb);
watchFile(pathPkg, cb);
const ctx: Context = {
clipboard: {
@@ -298,3 +299,23 @@ function prefixStdout(s: string) {
return newText.trimEnd();
});
}
const watchedFiles: Record<string, Stats> = {};
/**
* Watch a file and trigger callback on change.
*
* We also track the stat for each file because fs.watch will
* trigger a "change" event when the access date changes
*/
function watchFile(filepath: string, cb: (filepath: string) => void) {
watch(filepath, (_event, _name) => {
const stat = statSync(filepath);
if (stat.mtimeMs !== watchedFiles[filepath]?.mtimeMs) {
cb(filepath);
} else {
console.log('SKIPPING SAME FILE STAT', filepath, stat);
}
watchedFiles[filepath] = stat;
});
}