Archive/rdio-scanner
1
0
Fork 0
mirror of https://github.com/chuot/rdio-scanner.git synced 2026-08-14 17:03:02 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add a 2 seconds delay on DirWatch to give time for the meta file to be created

Browse source
This commit is contained in:
Chrystian Huot 2020-05-20 13:31:44 -04:00
parent 349d69419f
commit ed16727ce7
1 changed files with 43 additions and 39 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -90,61 +90,65 @@ class DirWatch {
switch (dirWatch.type) {
case 'trunk-recorder': {
const metaFile = path.resolve(file.dir, `${file.name}.json`);
setTimeout(() => {
const metaFile = path.resolve(file.dir, `${file.name}.json`);
if (!fs.existsSync(metaFile)) {
console.error(`File not found: ${metaFile}`);
if (!fs.existsSync(metaFile)) {
console.error(`File not found: ${metaFile}`);
return;
}
let meta;
try {
meta = JSON.parse(fs.readFileSync(metaFile, 'utf8'));
} catch (error) {
console.error(`Error loading file ${metaFile}`);
return;
}
if (meta) {
await this.app.controller.importTrunkRecorder(audio, audioName, audioType, system, meta);
if (dirWatch.deleteAfter) {
this.unlink(metaFile);
return;
}
}
let meta;
try {
meta = JSON.parse(fs.readFileSync(metaFile, 'utf8'));
} catch (error) {
console.error(`Error loading file ${metaFile}`);
return;
}
if (meta) {
await this.app.controller.importTrunkRecorder(audio, audioName, audioType, system, meta);
if (dirWatch.deleteAfter) {
this.unlink(metaFile);
}
}
}, 2000);
break;
}
case 'sdrtrunk': {
const metaFile = path.resolve(file.dir, `${file.name}.mbe`);
setTimeout(() => {
const metaFile = path.resolve(file.dir, `${file.name}.mbe`);
if (!fs.existsSync(metaFile)) {
console.error(`File not found: ${metaFile}`);
if (!fs.existsSync(metaFile)) {
console.error(`File not found: ${metaFile}`);
return;
}
return;
}
let meta;
let meta;
try {
meta = JSON.parse(fs.readFileSync(metaFile, 'utf8'));
try {
meta = JSON.parse(fs.readFileSync(metaFile, 'utf8'));
} catch (error) {
console.error(`Error loading file ${metaFile}`);
} catch (error) {
console.error(`Error loading file ${metaFile}`);
return;
}
return;
}
await this.app.controller.importSdrtrunk(audio, audioName, audioType, system, meta);
await this.app.controller.importSdrtrunk(audio, audioName, audioType, system, meta);
if (dirWatch.deleteAfter) {
this.unlink(metaFile);
}
if (dirWatch.deleteAfter) {
this.unlink(metaFile);
}
}, 2000);
break;
}