Merge pull request Sofie-Automation#1262 from bbc/upstream/routeset-config-defined-in-blueprints

feat: routeset config defined in blueprints

Author: nytamin

meteor/__mocks__/defaultCollectionObjects.ts

@@ -112,8 +112,8 @@ export function defaultStudio(_id: StudioId): DBStudio {
 			fallbackPartDuration: DEFAULT_FALLBACK_PART_DURATION,
 		},
 		_rundownVersionHash: '',
-		routeSets: {},
-		routeSetExclusivityGroups: {},
+		routeSetsWithOverrides: wrapDefaultObject({}),
+		routeSetExclusivityGroupsWithOverrides: wrapDefaultObject({}),
 		packageContainers: {},
 		previewContainerIds: [],
 		thumbnailContainerIds: [],

meteor/server/api/deviceTriggers/StudioDeviceTriggerManager.ts

@@ -56,7 +56,7 @@ export class StudioDeviceTriggerManager {
 			return
 		}
 
-		const context = createCurrentContextFromCache(cache)
+		const context = createCurrentContextFromCache(cache, studioId)
 		const actionManager = StudioActionManagers.get(studioId)
 		if (!actionManager)
 			throw new Meteor.Error(
@@ -271,7 +271,7 @@ function convertDocument(doc: ReadonlyObjectDeep<DBTriggeredActions>): UITrigger
 	})
 }
 
-function createCurrentContextFromCache(cache: ContentCache): ReactivePlaylistActionContext {
+function createCurrentContextFromCache(cache: ContentCache, studioId: StudioId): ReactivePlaylistActionContext {
 	const rundownPlaylist = cache.RundownPlaylists.findOne({
 		activationId: {
 			$exists: true,
@@ -301,6 +301,7 @@ function createCurrentContextFromCache(cache: ContentCache): ReactivePlaylistAct
 		: []
 
 	return {
+		studioId: new DummyReactiveVar(studioId),
 		currentPartInstanceId: new DummyReactiveVar(currentPartInstance?._id ?? null),
 		currentPartId: new DummyReactiveVar(currentPartInstance?.part._id ?? null),
 		nextPartId: new DummyReactiveVar(nextPartInstance?.part._id ?? null),

meteor/server/api/deviceTriggers/triggersContext.ts

@@ -132,6 +132,7 @@ function createContextForRundownPlaylistChain(
 	}
 
 	return {
+		studioId: new DummyReactiveVar(studioId),
 		rundownPlaylistId: new DummyReactiveVar(playlist?._id),
 		rundownPlaylist: new DummyReactiveVar(playlist),
 		currentRundownId: new DummyReactiveVar(currentPartInstance?.rundownId ?? playlist.rundownIdsInOrder[0] ?? null),

meteor/server/api/ingest/mosDevice/actions.ts

@@ -1,4 +1,3 @@
-import { MOS } from '@sofie-automation/corelib'
 import { logger } from '../../../logging'
 import { Rundown } from '@sofie-automation/corelib/dist/dataModel/Rundown'
 import { Meteor } from 'meteor/meteor'
@@ -13,7 +12,7 @@ import { generateRundownSource, getPeripheralDeviceFromRundown, runIngestOperati
 import { IngestJobs } from '@sofie-automation/corelib/dist/worker/ingest'
 import { DEFAULT_MOS_TIMEOUT_TIME } from '@sofie-automation/shared-lib/dist/core/constants'
 import { executePeripheralDeviceFunctionWithCustomTimeout } from '../../peripheralDevice/executeFunction'
-import { getMosTypes } from '@mos-connection/helper'
+import { MOS } from '@sofie-automation/meteor-lib/dist/mos'
 
 export namespace MOSDeviceActions {
 	export async function reloadRundown(
@@ -73,7 +72,7 @@ export namespace MOSDeviceActions {
 		if (!mosPayload.Body)
 			throw new Meteor.Error(500, `Part Cache for "${partCache.externalId}" missing FullStory content!`)
 
-		const mosTypes = getMosTypes(false)
+		const mosTypes = MOS.getMosTypes(false)
 
 		const story = mosPayload.Body.find(
 			(item) =>

meteor/server/api/playout/playout.ts

@@ -1,12 +1,10 @@
 /* tslint:disable:no-use-before-declare */
-import { Meteor } from 'meteor/meteor'
-import * as _ from 'underscore'
-import { StudioRouteBehavior } from '@sofie-automation/corelib/dist/dataModel/Studio'
 import { PackageInfo } from '../../coreSystem'
 import { StudioContentAccess } from '../../security/studio'
 import { shouldUpdateStudioBaselineInner } from '@sofie-automation/corelib/dist/studio/baseline'
-import { logger } from '../../logging'
-import { Blueprints, RundownPlaylists, Studios, Timeline } from '../../collections'
+import { Blueprints, RundownPlaylists, Timeline } from '../../collections'
+import { StudioJobs } from '@sofie-automation/corelib/dist/worker/studio'
+import { QueueStudioJob } from '../../worker/worker'
 
 export namespace ServerPlayoutAPI {
 	export async function shouldUpdateStudioBaseline(access: StudioContentAccess): Promise<string | false> {
@@ -38,32 +36,12 @@ export namespace ServerPlayoutAPI {
 	export async function switchRouteSet(
 		access: StudioContentAccess,
 		routeSetId: string,
-		state: boolean
+		state: boolean | 'toggle'
 	): Promise<void> {
-		logger.debug(`switchRouteSet "${access.studioId}" "${routeSetId}"=${state}`)
-
-		const studio = access.studio
-
-		if (studio.routeSets[routeSetId] === undefined)
-			throw new Meteor.Error(404, `RouteSet "${routeSetId}" not found!`)
-		const routeSet = studio.routeSets[routeSetId]
-		if (routeSet.behavior === StudioRouteBehavior.ACTIVATE_ONLY && state === false)
-			throw new Meteor.Error(400, `RouteSet "${routeSetId}" is ACTIVATE_ONLY`)
-
-		const modification: Record<string, any> = {}
-		modification[`routeSets.${routeSetId}.active`] = state
-
-		if (studio.routeSets[routeSetId].exclusivityGroup && state === true) {
-			_.each(studio.routeSets, (otherRouteSet, otherRouteSetId) => {
-				if (otherRouteSetId === routeSetId) return
-				if (otherRouteSet.exclusivityGroup === routeSet.exclusivityGroup) {
-					modification[`routeSets.${otherRouteSetId}.active`] = false
-				}
-			})
-		}
-
-		await Studios.updateAsync(studio._id, {
-			$set: modification,
+		const queuedJob = await QueueStudioJob(StudioJobs.SwitchRouteSet, access.studioId, {
+			routeSetId,
+			state,
 		})
+		await queuedJob.complete
 	}
 }

meteor/server/api/rest/v1/typeConversion.ts

@@ -276,9 +276,9 @@ export async function studioFrom(apiStudio: APIStudio, existingId?: StudioId): P
 		supportedShowStyleBase: apiStudio.supportedShowStyleBase?.map((id) => protectString<ShowStyleBaseId>(id)) ?? [],
 		organizationId: null,
 		mappingsWithOverrides: wrapDefaultObject({}),
-		routeSets: {},
+		routeSetsWithOverrides: wrapDefaultObject({}),
 		_rundownVersionHash: '',
-		routeSetExclusivityGroups: {},
+		routeSetExclusivityGroupsWithOverrides: wrapDefaultObject({}),
 		packageContainers: {},
 		previewContainerIds: [],
 		thumbnailContainerIds: [],

meteor/server/api/studio/api.ts

@@ -50,8 +50,8 @@ export async function insertStudioInner(organizationId: OrganizationId | null, n
 				minimumTakeSpan: DEFAULT_MINIMUM_TAKE_SPAN,
 			},
 			_rundownVersionHash: '',
-			routeSets: {},
-			routeSetExclusivityGroups: {},
+			routeSetsWithOverrides: wrapDefaultObject({}),
+			routeSetExclusivityGroupsWithOverrides: wrapDefaultObject({}),
 			packageContainers: {},
 			thumbnailContainerIds: [],
 			previewContainerIds: [],
@@ -141,7 +141,7 @@ Studios.observeChanges(
 	{
 		fields: {
 			mappingsWithOverrides: 1,
-			routeSets: 1,
+			routeSetsWithOverrides: 1,
 		},
 	}
 )

meteor/server/api/userActions.ts

@@ -1114,7 +1114,7 @@ class ServerUserActionAPI
 		eventTime: Time,
 		studioId: StudioId,
 		routeSetId: string,
-		state: boolean
+		state: boolean | 'toggle'
 	): Promise<ClientAPI.ClientResponse<void>> {
 		return ServerClientAPI.runUserActionInLog(
 			this,
@@ -1125,7 +1125,7 @@ class ServerUserActionAPI
 			async () => {
 				check(studioId, String)
 				check(routeSetId, String)
-				check(state, Boolean)
+				check(state, Match.OneOf('toggle', Boolean))
 
 				const access = await StudioContentWriteAccess.routeSet(this, studioId)
 				return ServerPlayoutAPI.switchRouteSet(access, routeSetId, state)

meteor/server/migration/0_1_0.ts

@@ -445,8 +445,8 @@ export const addSteps = addMigrationSteps('0.1.0', [
 				mappingsWithOverrides: wrapDefaultObject({}),
 				blueprintConfigWithOverrides: wrapDefaultObject({}),
 				_rundownVersionHash: '',
-				routeSets: {},
-				routeSetExclusivityGroups: {},
+				routeSetsWithOverrides: wrapDefaultObject({}),
+				routeSetExclusivityGroupsWithOverrides: wrapDefaultObject({}),
 				packageContainers: {},
 				thumbnailContainerIds: [],
 				previewContainerIds: [],