mirror of
https://github.com/gabehf/Tdarr_Plugins.git
synced 2026-03-17 03:06:27 -07:00
Flow Run Health Check updates stats and queues
This commit is contained in:
parent
e142db1892
commit
80563106dd
2 changed files with 14 additions and 1 deletions
|
|
@ -97,11 +97,22 @@ const plugin = async (args:IpluginInputArgs):Promise<IpluginOutputArgs> => {
|
||||||
|
|
||||||
const res = await cli.runCli();
|
const res = await cli.runCli();
|
||||||
|
|
||||||
|
// Added in 2.19.01
|
||||||
|
if (typeof args.updateStat !== 'undefined') {
|
||||||
|
await args.updateStat(args.originalLibraryFile.DB, 'totalHealthCheckCount', 1);
|
||||||
|
}
|
||||||
|
|
||||||
if (res.cliExitCode !== 0) {
|
if (res.cliExitCode !== 0) {
|
||||||
args.jobLog('Running CLI failed');
|
args.jobLog('Running CLI failed');
|
||||||
|
args.logOutcome('hErr');
|
||||||
throw new Error('Running CLI failed');
|
throw new Error('Running CLI failed');
|
||||||
}
|
}
|
||||||
|
|
||||||
|
args.logOutcome('hSuc');
|
||||||
|
|
||||||
|
// will cause item to go into the health check success table
|
||||||
|
args.variables.healthCheck = 'Success';
|
||||||
|
|
||||||
return {
|
return {
|
||||||
outputFileObj: args.inputFileObj,
|
outputFileObj: args.inputFileObj,
|
||||||
outputNumber: 1,
|
outputNumber: 1,
|
||||||
|
|
|
||||||
|
|
@ -100,6 +100,7 @@ export interface Ivariables {
|
||||||
ffmpegCommand: IffmpegCommand,
|
ffmpegCommand: IffmpegCommand,
|
||||||
flowFailed: boolean,
|
flowFailed: boolean,
|
||||||
user: Record<string, string>,
|
user: Record<string, string>,
|
||||||
|
healthCheck?: 'Success',
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface IpluginOutputArgs {
|
export interface IpluginOutputArgs {
|
||||||
|
|
@ -137,7 +138,8 @@ export interface IpluginInputArgs {
|
||||||
updateWorker: IupdateWorker,
|
updateWorker: IupdateWorker,
|
||||||
logFullCliOutput: boolean,
|
logFullCliOutput: boolean,
|
||||||
logOutcome: (outcome: string) => void,
|
logOutcome: (outcome: string) => void,
|
||||||
scanIndividualFile?: (filee: IFileObjectMin, scanTypes: IscanTypes) => IFileObject,
|
scanIndividualFile?: (filee: IFileObjectMin, scanTypes: IscanTypes) => Promise<IFileObject>,
|
||||||
|
updateStat: (db: string, key: string, inc: number) => Promise<void>,
|
||||||
deps: {
|
deps: {
|
||||||
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
||||||
fsextra: any,
|
fsextra: any,
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue