mirror/api
1
0
Fork 0
mirror of https://github.com/unraid/api.git synced 2026-01-16 21:50:18 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix: always use varState for regFile path

Browse Source
This commit is contained in:
Alexis Tyler
2021-05-03 18:24:28 +09:30
parent 4ad0c334c3
commit 1263b9b52d
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
app/core/watchers/registration.ts
View File

@@ -11,10 +11,7 @@ import { pubsub } from '../pubsub';
import { getKeyFile, sleep } from '../utils';
import { bus } from '../bus';
const processChange = async function (fullPath: string) {
// Wait for var state to settle with the newest data
await sleep(100);
const processChange = async function () {
logger.debug(varState.data.regFile ? `Checking "${varState.data.regFile}" for the key file.` : 'No key file found.');
// Get key file
@@ -24,7 +21,7 @@ const processChange = async function (fullPath: string) {
type: varState.data.regTy.toUpperCase(),
state: varState.data.regState,
keyFile: {
location: fullPath,
location: varState.data.regFile,
contents: keyFile
}
};
@@ -69,7 +66,7 @@ export const keyFile = () => {
coreLogger.debug('Registration file %s has emitted %s event.', filePath, event);
// Process the changes
await processChange(filePath).catch(error => {
await processChange().catch(error => {
coreLogger.error('Failed processing watcher "%s" event with %s', event, error);
});
});
@@ -83,7 +80,7 @@ export const keyFile = () => {
coreLogger.debug('Var state updated, publishing registration event.');
// Process the changes
await processChange(data.regFile).catch(error => {
await processChange().catch(error => {
coreLogger.error('Failed processing bus update for "varState" with %s', error);
});
});