Archive/rdio-scanner
1
0
Fork 0
mirror of https://github.com/chuot/rdio-scanner.git synced 2026-08-13 16:33:01 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

New dirWatch logic when injesting meta files

Browse source
This commit is contained in:
Chrystian Huot 2020-05-20 15:07:24 -04:00
parent b7fbde0e63
commit bbe40de6ce
1 changed files with 24 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
server/lib/rdio-scanner/dir-watch.js
View file

@ -82,22 +82,22 @@ class DirWatch {
const talkgroup = parse(dirWatch.talkgroup);
if (isNaN(system) || isNaN(talkgroup)) {
console.log(`Unknown system or talkgroup for ${filename}`);
return;
}
switch (dirWatch.type) {
case 'trunk-recorder': {
setTimeout(async () => {
const metaFile = path.resolve(file.dir, `${file.name}.json`);
const metaFile = path.resolve(file.dir, `${file.name}.json`);
if (!fs.existsSync(metaFile)) {
console.error(`File not found: ${metaFile}`);
const metaWatcher = chokidar.watch(metaFile, { awaitWriteFinish: true });
return;
const timeout = setTimeout(() => {
if (!metaWatcher.closed) {
metaWatcher.close();
}
}, 60 * 1000);
metaWatcher.on('add', async () => {
clearTimeout(timeout);
await metaWatcher.close();
let meta;
@ -117,20 +117,26 @@ class DirWatch {
this.unlink(metaFile);
}
}
}, 2000);
});
break;
}
case 'sdrtrunk': {
setTimeout(async () => {
const metaFile = path.resolve(file.dir, `${file.name}.mbe`);
const metaFile = path.resolve(file.dir, `${file.name}.mbe`);
if (!fs.existsSync(metaFile)) {
console.error(`File not found: ${metaFile}`);
const metaWatcher = chokidar.watch(metaFile, { awaitWriteFinish: true });
return;
const timeout = setTimeout(() => {
if (!metaWatcher.closed) {
metaWatcher.close();
}
}, 60 * 1000);
metaWatcher.on('add', async () => {
clearTimeout(timeout);
await metaWatcher.close();
let meta;
@ -148,7 +154,7 @@ class DirWatch {
if (dirWatch.deleteAfter) {
this.unlink(metaFile);
}
}, 2000);
});
break;
}