Skip to content

fix: reorder the kairos monitor messages #462

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
nytamin wants to merge 1 commit into
base: main
Choose a base branch
from
Open

fix: reorder the kairos monitor messages #462

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
64 changes: 36 additions & 28 deletions packages/timeline-state-resolver/src/integrations/kairos/kairos-application-monitor.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -240,17 +240,20 @@ export class KairosApplicationMonitor extends EventEmitter<KairosApplicationMoni
private async checkApplicationStatus() {
this.applyMappings()

const issues: string[] = []
const ensureExists = async (pExists: Promise<boolean>, description: string): Promise<void> => {
const highPrioIssues: string[] = []
const lowPrioIssues: string[] = []
const ensureExists = async (pExists: Promise<boolean>, description: string, highPrio: boolean): Promise<void> => {
try {
const value = await pExists

if (value === false) {
issues.push(`${description} not found on the Kairos.`)
if (highPrio) highPrioIssues.push(`${description} not found on the Kairos.`)
else lowPrioIssues.push(`${description} not found on the Kairos.`)
}
} catch (e) {
if (e instanceof ResponseError) {
issues.push(`${description}) not found on the Kairos.`)
if (highPrio) highPrioIssues.push(`${description}) not found on the Kairos.`)
else lowPrioIssues.push(`${description}) not found on the Kairos.`)
} else {
this.emit('error', e instanceof Error ? e : new Error(e + ''))
}
Expand All @@ -266,71 +269,76 @@ export class KairosApplicationMonitor extends EventEmitter<KairosApplicationMoni
}

if (sourceRef.realm === 'clipPlayer') {
await ensureExists(this.kairos.clipPlayerExists(sourceRef), `Clip Player "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.clipPlayerExists(sourceRef), `Clip Player "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'ramRecorder') {
await ensureExists(this.kairos.ramRecorderExists(sourceRef), `Ram Recorder "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.ramRecorderExists(sourceRef), `Ram Recorder "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'imageStore') {
await ensureExists(this.kairos.imageStoreExists(sourceRef), `Image Store "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.imageStoreExists(sourceRef), `Image Store "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'scene') {
await ensureExists(this.kairos.sceneExists(sourceRef), `Scene "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.sceneExists(sourceRef), `Scene "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'ip-input') {
await ensureExists(this.kairos.inputExists(sourceRef), `IP Input "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.inputExists(sourceRef), `IP Input "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'sdi-input') {
await ensureExists(this.kairos.inputExists(sourceRef), `SDI Input "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.inputExists(sourceRef), `SDI Input "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'ndi-input') {
await ensureExists(this.kairos.inputExists(sourceRef), `NDI Input "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.inputExists(sourceRef), `NDI Input "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'stream-input') {
await ensureExists(this.kairos.inputExists(sourceRef), `Stream Input "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.inputExists(sourceRef), `Stream Input "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'hdmi-input') {
await ensureExists(this.kairos.inputExists(sourceRef), `HDMI Input "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.inputExists(sourceRef), `HDMI Input "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'media-still') {
await ensureExists(this.kairos.mediaStillExists(sourceRef), `Media Still "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.mediaStillExists(sourceRef), `Media Still "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'media-ramrec') {
await ensureExists(this.kairos.mediaRamRecExists(sourceRef), `Media RamRec "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.mediaRamRecExists(sourceRef), `Media RamRec "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'matte') {
// There is no method to check a matte individually (yet)
} else if (sourceRef.realm === 'gfx-channel') {
await ensureExists(this.kairos.gfxChannelExists(sourceRef), `GFX Channel "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.gfxChannelExists(sourceRef), `GFX Channel "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'source-base') {
// Ignore, eg: BLACK / WHITE
} else if (sourceRef.realm === 'source-int') {
// Ignore, eg: ColorBar / ColorCircle
} else if (sourceRef.realm === 'mv-int') {
await ensureExists(
this.kairos.multiViewerSourceExists(sourceRef),
`MultiViewer Source "${refToPath(sourceRef)}"`
`MultiViewer Source "${refToPath(sourceRef)}"`,
true
)
} else if (sourceRef.realm === 'scene-snapshot') {
await ensureExists(this.kairos.sceneSnapshotExists(sourceRef), `Scene Snapshot "${refToPath(sourceRef)}"`)
await ensureExists(
this.kairos.sceneSnapshotExists(sourceRef),
`Scene Snapshot "${refToPath(sourceRef)}"`,
false
)
} else if (sourceRef.realm === 'scene-layer') {
await ensureExists(this.kairos.sceneLayerExists(sourceRef), `Scene Layer "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.sceneLayerExists(sourceRef), `Scene Layer "${refToPath(sourceRef)}"`, false)
} else if (sourceRef.realm === 'macro') {
await ensureExists(this.kairos.macroExists(sourceRef), `Macro "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.macroExists(sourceRef), `Macro "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'media-sound') {
await ensureExists(this.kairos.mediaSoundExists(sourceRef), `Media Sound "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.mediaSoundExists(sourceRef), `Media Sound "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'audio-player') {
await ensureExists(this.kairos.audioPlayerExists(sourceRef), `Audio Player "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.audioPlayerExists(sourceRef), `Audio Player "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'scene-layer-effect') {
const layerRef = refSceneLayer(refScene(sourceRef.scenePath), sourceRef.layerPath)
const layerEffects = await this.kairos.listSceneLayerEffects(layerRef)

if (!layerEffects.find((effect) => _.isEqual(effect.effectPath, sourceRef.effectPath))) {
issues.push(`Layer Effect ${refToPath(sourceRef)} not found on the Kairos.`)
lowPrioIssues.push(`Layer Effect ${refToPath(sourceRef)} not found on the Kairos.`)
}
} else if (sourceRef.realm === 'aux') {
await ensureExists(this.kairos.auxExists(sourceRef), `Aux "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.auxExists(sourceRef), `Aux "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'media-clip') {
await ensureExists(this.kairos.mediaClipExists(sourceRef), `Media Clip "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.mediaClipExists(sourceRef), `Media Clip "${refToPath(sourceRef)}"`, true)
} else if (sourceRef.realm === 'media-image') {
await ensureExists(this.kairos.mediaImageExists(sourceRef), `Media Image "${refToPath(sourceRef)}"`)
await ensureExists(this.kairos.mediaImageExists(sourceRef), `Media Image "${refToPath(sourceRef)}"`, true)
} else {
assertNever(sourceRef)
}
}

const status: DeviceStatus = {
statusCode: issues.length > 0 ? StatusCode.BAD : StatusCode.GOOD,
messages: issues,
statusCode: highPrioIssues.length + lowPrioIssues.length > 0 ? StatusCode.BAD : StatusCode.GOOD,
messages: [...highPrioIssues, ...lowPrioIssues],
active: true,
}
if (!_.isEqual(this.status, status)) {
Expand Down
Loading