wip: something

Author: Julusian

meteor/server/api/deviceTriggers/StudioDeviceTriggerManager.ts

@@ -30,6 +30,8 @@ import { SomeAction, SomeBlueprintTrigger } from '@sofie-automation/blueprints-i
 import { DeviceActions } from '@sofie-automation/shared-lib/dist/core/model/ShowStyle'
 import { DummyReactiveVar } from '@sofie-automation/meteor-lib/dist/triggers/reactive-var'
 import { MeteorTriggersContext } from './triggersContext'
+import { Tracker } from 'meteor/tracker'
+import { TriggerTrackerComputation } from '@sofie-automation/meteor-lib/dist/triggers/triggersContext'
 
 export class StudioDeviceTriggerManager {
 	#lastShowStyleBaseId: ShowStyleBaseId | null = null
@@ -43,7 +45,11 @@ export class StudioDeviceTriggerManager {
 		StudioActionManagers.set(studioId, new StudioActionManager())
 	}
 
-	updateTriggers(cache: ContentCache, showStyleBaseId: ShowStyleBaseId): void {
+	async updateTriggers(
+		cache: ContentCache,
+		showStyleBaseId: ShowStyleBaseId,
+		computation: Tracker.Computation | null
+	): Promise<void> {
 		const studioId = this.studioId
 		this.#lastShowStyleBaseId = showStyleBaseId
 
@@ -88,7 +94,7 @@ export class StudioDeviceTriggerManager {
 
 			const addedPreviewIds: PreviewWrappedAdLibId[] = []
 
-			Object.entries<SomeAction>(triggeredAction.actions).forEach(([key, action]) => {
+			for (const [key, action] of Object.entries<SomeAction>(triggeredAction.actions)) {
 				// Since the compiled action is cached using this actionId as a key, having the action
 				// and the filterChain allows for a quicker invalidation without doing a deepEquals
 				const actionId = protectString<DeviceActionId>(
@@ -106,7 +112,7 @@ export class StudioDeviceTriggerManager {
 				}
 				touchedActionIds.push(actionId)
 
-				Object.entries<SomeBlueprintTrigger>(triggeredAction.triggers).forEach(([key, trigger]) => {
+				for (const [key, trigger] of Object.entries<SomeBlueprintTrigger>(triggeredAction.triggers)) {
 					if (!isDeviceTrigger(trigger)) {
 						return
 					}
@@ -141,7 +147,7 @@ export class StudioDeviceTriggerManager {
 						},
 					})
 					upsertedDeviceTriggerMountedActionIds.push(deviceTriggerMountedActionId)
-				})
+				}
 
 				if (!isPreviewableAction(thisAction)) {
 					const adLibPreviewId = protectString(`${actionId}_preview`)
@@ -165,7 +171,10 @@ export class StudioDeviceTriggerManager {
 
 					addedPreviewIds.push(adLibPreviewId)
 				} else {
-					const previewedAdLibs = thisAction.preview(context)
+					const previewedAdLibs = await thisAction.preview(
+						context,
+						computation as any as TriggerTrackerComputation | null
+					)
 
 					previewedAdLibs.forEach((adLib) => {
 						const adLibPreviewId = protectString<PreviewWrappedAdLibId>(
@@ -195,7 +204,7 @@ export class StudioDeviceTriggerManager {
 						addedPreviewIds.push(adLibPreviewId)
 					})
 				}
-			})
+			}
 
 			DeviceTriggerMountedActionAdlibsPreview.remove({
 				triggeredActionId: triggeredAction._id,

meteor/server/api/deviceTriggers/observer.ts

@@ -44,7 +44,7 @@ Meteor.startup(() => {
 		const manager = new StudioDeviceTriggerManager(studioId)
 		const observer = new StudioObserver(studioId, (showStyleBaseId, cache) => {
 			workInQueue(async () => {
-				manager.updateTriggers(cache, showStyleBaseId)
+				await manager.updateTriggers(cache, showStyleBaseId, null) // nocommit - confirm this
 			})
 
 			return () => {

meteor/server/api/deviceTriggers/triggersContext.ts

@@ -1,6 +1,10 @@
-import { TriggersContext } from '@sofie-automation/meteor-lib/dist/triggers/triggersContext'
+import {
+	TriggersAsyncCollection,
+	TriggersContext,
+	TriggerTrackerComputation,
+} from '@sofie-automation/meteor-lib/dist/triggers/triggersContext'
 import { SINGLE_USE_TOKEN_SALT } from '@sofie-automation/meteor-lib/dist/api/userActions'
-import { assertNever, getHash, Time } from '../../lib/tempLib'
+import { assertNever, getHash, ProtectedString, Time } from '../../lib/tempLib'
 import { getCurrentTime } from '../../lib/lib'
 import { MeteorCall } from '../methods'
 import { ClientAPI } from '@sofie-automation/meteor-lib/dist/api/client'
@@ -28,26 +32,57 @@ import {
 } from '../../collections'
 import { DBPart } from '@sofie-automation/corelib/dist/dataModel/Part'
 import { DBPartInstance } from '@sofie-automation/corelib/dist/dataModel/PartInstance'
+import { AsyncOnlyReadOnlyMongoCollection } from '../../collections/collection'
 
 export function hashSingleUseToken(token: string): string {
 	return getHash(SINGLE_USE_TOKEN_SALT + token)
 }
 
+class TriggersCollection2<DBInterface extends { _id: ProtectedString<any> }>
+	implements TriggersAsyncCollection<DBInterface>
+{
+	readonly #collection: AsyncOnlyReadOnlyMongoCollection<DBInterface>
+
+	constructor(collection: AsyncOnlyReadOnlyMongoCollection<DBInterface>) {
+		this.#collection = collection
+	}
+
+	async findFetchAsync(
+		computation: TriggerTrackerComputation | null,
+		selector: any,
+		options?: any
+	): Promise<Array<DBInterface>> {
+		return Tracker.withComputation(computation as Tracker.Computation | null, async () => {
+			return this.#collection.findFetchAsync(selector, options)
+		})
+	}
+
+	async findOneAsync(
+		computation: TriggerTrackerComputation | null,
+		selector: any,
+		options?: any
+	): Promise<DBInterface | undefined> {
+		return Tracker.withComputation(computation as Tracker.Computation | null, async () => {
+			return this.#collection.findOneAsync(selector, options)
+		})
+	}
+}
+
 export const MeteorTriggersContext: TriggersContext = {
 	MeteorCall,
 
 	logger,
 
 	isClient: false,
 
-	AdLibActions,
-	AdLibPieces,
-	Parts,
-	RundownBaselineAdLibActions,
-	RundownBaselineAdLibPieces,
-	RundownPlaylists,
-	Rundowns,
-	Segments,
+	AdLibActions: new TriggersCollection2(AdLibActions),
+	AdLibPieces: new TriggersCollection2(AdLibPieces),
+	Parts: new TriggersCollection2(Parts),
+	RundownBaselineAdLibActions: new TriggersCollection2(RundownBaselineAdLibActions),
+	RundownBaselineAdLibPieces: new TriggersCollection2(RundownBaselineAdLibPieces),
+	RundownPlaylists: new TriggersCollection2(RundownPlaylists),
+	Rundowns: new TriggersCollection2(Rundowns),
+	Segments: new TriggersCollection2(Segments),
 
 	hashSingleUseToken,
 
@@ -67,14 +102,17 @@ export const MeteorTriggersContext: TriggersContext = {
 		)
 	},
 
-	nonreactiveTracker: Tracker.nonreactive,
+	withComputation: async (computation, func) => {
+		return Tracker.withComputation(computation as Tracker.Computation | null, func)
+	},
 
 	memoizedIsolatedAutorun: async <TArgs extends any[], TRes>(
-		fnc: (...args: TArgs) => Promise<TRes>,
+		computation: TriggerTrackerComputation | null,
+		fnc: (computation: TriggerTrackerComputation | null, ...args: TArgs) => Promise<TRes>,
 		_functionName: string,
 		...params: TArgs
 	): Promise<TRes> => {
-		return fnc(...params)
+		return fnc(computation, ...params)
 	},
 
 	createContextForRundownPlaylistChain,