diff --git a/apps/server/src/adapters/websocketAux.ts b/apps/server/src/adapters/websocketAux.ts index bba45180f..4626e904b 100644 --- a/apps/server/src/adapters/websocketAux.ts +++ b/apps/server/src/adapters/websocketAux.ts @@ -1,5 +1,10 @@ import { socket } from './WebsocketAdapter.js'; +export enum RefetchTargets { + Rundown = 'rundown', + Report = 'report', +} + /** * Utility function to notify clients that the REST data is stale * @param payload -- possible patch payload diff --git a/apps/server/src/api-data/report/report.service.ts b/apps/server/src/api-data/report/report.service.ts index c453d9509..0b3d358a3 100644 --- a/apps/server/src/api-data/report/report.service.ts +++ b/apps/server/src/api-data/report/report.service.ts @@ -1,6 +1,6 @@ import { OntimeReport, OntimeEventReport, TimerLifeCycle } from 'ontime-types'; import { RuntimeState } from '../../stores/runtimeState.js'; -import { sendRefetch } from '../../adapters/websocketAux.js'; +import { RefetchTargets, sendRefetch } from '../../adapters/websocketAux.js'; import { DeepReadonly } from 'ts-essentials'; const report = new Map(); @@ -58,7 +58,7 @@ export function triggerReportEntry( report.set(eventId, { startedAt, endedAt: state.clock }); formattedReport = null; sendRefetch({ - target: 'REPORT', + target: RefetchTargets.Report, }); } } diff --git a/apps/server/src/services/rundown-service/RundownService.ts b/apps/server/src/services/rundown-service/RundownService.ts index 2bc5b90b0..2b7b8e2f3 100644 --- a/apps/server/src/services/rundown-service/RundownService.ts +++ b/apps/server/src/services/rundown-service/RundownService.ts @@ -15,7 +15,7 @@ import { import { getCueCandidate } from 'ontime-utils'; import { delay as delayDef } from '../../models/eventsDefinition.js'; -import { sendRefetch } from '../../adapters/websocketAux.js'; +import { RefetchTargets, sendRefetch } from '../../adapters/websocketAux.js'; import { createBlock, createEvent } from '../../api-data/rundown/rundown.utils.js'; import { updateRundownData } from '../../stores/runtimeState.js'; import { runtimeService } from '../runtime-service/RuntimeService.js'; @@ -334,7 +334,7 @@ function notifyChanges(options: NotifyChangesOptions) { if (options.external) { // advice socket subscribers of change const payload = { - target: 'RUNDOWN', + target: RefetchTargets.Rundown, changes: Array.isArray(options.timer) ? options.timer : undefined, reload: options.reload, revision: cache.getMetadata().revision,