feat: time of day pieces SOFIE-197 (#43)

Author: Julusian

meteor/__mocks__/helpers/database.ts

@@ -468,6 +468,7 @@ export async function setupMockShowStyleBlueprint(
 						rundown,
 						globalAdLibPieces: [],
 						globalActions: [],
+						globalPieces: [],
 						baseline: { timelineObjects: [] },
 					}
 				},

meteor/server/api/deviceTriggers/TagsService.ts

@@ -4,12 +4,14 @@ import { PieceInstance } from '@sofie-automation/corelib/dist/dataModel/PieceIns
 import { PieceInstanceFields, ContentCache } from './reactiveContentCacheForPieceInstances'
 import { SourceLayers } from '@sofie-automation/corelib/dist/dataModel/ShowStyleBase'
 import {
+	createPartCurrentTimes,
 	PieceInstanceWithTimings,
 	processAndPrunePieceInstanceTimings,
 } from '@sofie-automation/corelib/dist/playout/processAndPrune'
 import { applyAndValidateOverrides } from '@sofie-automation/corelib/dist/settings/objectWithOverrides'
 import { IWrappedAdLib } from '@sofie-automation/meteor-lib/dist/triggers/actionFilterChainCompilers'
 import { areSetsEqual, doSetsIntersect } from '@sofie-automation/corelib/dist/lib'
+import { getCurrentTime } from '../../lib/lib'
 
 export class TagsService {
 	protected onAirPiecesTags: Set<string> = new Set()
@@ -130,12 +132,11 @@ export class TagsService {
 	): PieceInstanceWithTimings[] {
 		// Approximate when 'now' is in the PartInstance, so that any adlibbed Pieces will be timed roughly correctly
 		const partStarted = partInstanceTimings?.plannedStartedPlayback
-		const nowInPart = partStarted === undefined ? 0 : Date.now() - partStarted
 
 		return processAndPrunePieceInstanceTimings(
 			sourceLayers,
 			pieceInstances as PieceInstance[],
-			nowInPart,
+			createPartCurrentTimes(getCurrentTime(), partStarted),
 			false,
 			false
 		)

meteor/server/api/ingest/packageInfo.ts

@@ -35,6 +35,7 @@ export async function onUpdatedPackageInfo(packageId: ExpectedPackageId, _doc: P
 			case ExpectedPackageDBType.ADLIB_ACTION:
 			case ExpectedPackageDBType.BASELINE_ADLIB_PIECE:
 			case ExpectedPackageDBType.BASELINE_ADLIB_ACTION:
+			case ExpectedPackageDBType.BASELINE_PIECE:
 			case ExpectedPackageDBType.RUNDOWN_BASELINE_OBJECTS:
 				onUpdatedPackageInfoForRundownDebounce(pkg)
 				break

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

@@ -388,6 +388,7 @@ export function studioSettingsFrom(apiStudioSettings: APIStudioSettings): Comple
 		allowPieceDirectPlay: apiStudioSettings.allowPieceDirectPlay ?? true, // Backwards compatible
 		enableBuckets: apiStudioSettings.enableBuckets ?? true, // Backwards compatible
 		enableEvaluationForm: apiStudioSettings.enableEvaluationForm ?? true, // Backwards compatible
+		rundownGlobalPiecesPrepareTime: apiStudioSettings.rundownGlobalPiecesPrepareTime,
 	}
 }
 
@@ -413,6 +414,7 @@ export function APIStudioSettingsFrom(settings: IStudioSettings): Complete<APISt
 		allowPieceDirectPlay: settings.allowPieceDirectPlay,
 		enableBuckets: settings.enableBuckets,
 		enableEvaluationForm: settings.enableEvaluationForm,
+		rundownGlobalPiecesPrepareTime: settings.rundownGlobalPiecesPrepareTime,
 	}
 }
 

meteor/server/lib/rest/v1/studios.ts

@@ -222,4 +222,5 @@ export interface APIStudioSettings {
 	allowPieceDirectPlay?: boolean
 	enableBuckets?: boolean
 	enableEvaluationForm?: boolean
+	rundownGlobalPiecesPrepareTime?: number
 }

meteor/server/migration/1_50_0.ts

@@ -917,7 +917,7 @@ export const addSteps = addMigrationSteps('1.50.0', [
 
 			const partIdLookup = new Map<PieceId | AdLibActionId | RundownBaselineAdLibActionId, PartId>()
 			for (const piece of pieces) {
-				partIdLookup.set(piece._id, piece.startPartId)
+				if (piece.startPartId) partIdLookup.set(piece._id, piece.startPartId)
 			}
 			for (const adlib of adlibPieces) {
 				if (adlib.partId) partIdLookup.set(adlib._id, adlib.partId)

meteor/server/publications/pieceContentStatusUI/rundown/regenerateItems.ts

@@ -107,7 +107,7 @@ export async function regenerateForPieceIds(
 				{
 					_id: protectString(`piece_${pieceId}`),
 
-					partId: pieceDoc.startPartId,
+					partId: pieceDoc.startPartId ?? undefined,
 					rundownId: pieceDoc.startRundownId,
 					pieceId: pieceId,
 
@@ -180,7 +180,7 @@ export async function regenerateForPieceInstanceIds(
 				const res: UIPieceContentStatus = {
 					_id: protectString(`piece_${pieceId}`),
 
-					partId: pieceDoc.piece.startPartId,
+					partId: pieceDoc.piece.startPartId ?? undefined,
 					rundownId: pieceDoc.rundownId,
 					pieceId: pieceId,
 

packages/blueprints-integration/src/api/showStyle.ts

@@ -35,6 +35,8 @@ import type {
 	IBlueprintSegment,
 	IBlueprintPiece,
 	IBlueprintPart,
+	IBlueprintRundownPiece,
+	IBlueprintRundownPieceDB,
 } from '../documents'
 import type { IBlueprintShowStyleVariant, IOutputLayer, ISourceLayer } from '../showStyle'
 import type { TSR, OnGenerateTimelineObj, TimelineObjectCoreExt } from '../timeline'
@@ -266,6 +268,7 @@ export interface BlueprintResultRundown {
 	rundown: IBlueprintRundown
 	globalAdLibPieces: IBlueprintAdLibPiece[]
 	globalActions: IBlueprintActionManifest[]
+	globalPieces: IBlueprintRundownPiece[]
 	baseline: BlueprintResultBaseline
 }
 export interface BlueprintResultSegment {
@@ -292,6 +295,11 @@ export interface BlueprintSyncIngestNewData {
 	actions: IBlueprintActionManifest[]
 	/** A list of adlibs that have pieceInstances in the partInstance in question */
 	referencedAdlibs: IBlueprintAdLibPieceDB[]
+	/**
+	 * The list of pieces which belong to the Rundown, and may be active
+	 * Note: Some of these may have played and been stopped before the current PartInstance
+	 */
+	rundownPieces: IBlueprintRundownPieceDB[]
 }
 
 // TODO: add something like this later?

packages/blueprints-integration/src/documents/index.ts

@@ -7,5 +7,6 @@ export * from './pieceInstance'
 export * from './pieceGeneric'
 export * from './playlistTiming'
 export * from './rundown'
+export * from './rundownPiece'
 export * from './rundownPlaylist'
 export * from './segment'

packages/blueprints-integration/src/documents/rundownPiece.ts

@@ -0,0 +1,29 @@
+import { IBlueprintPieceGeneric } from './pieceGeneric'
+
+/**
+ * A variant of a Piece, that is owned by the Rundown.
+ * This
+ */
+export interface IBlueprintRundownPiece<TPrivateData = unknown, TPublicData = unknown>
+	extends Omit<IBlueprintPieceGeneric<TPrivateData, TPublicData>, 'lifespan'> {
+	/** When the piece should be active on the timeline. */
+	enable: {
+		start: number
+		duration?: number
+
+		// For now, these pieces are always absolute (using wall time) rather than relative to the rundown
+		isAbsolute: true
+	}
+
+	/** Whether the piece is a real piece, or exists as a marker to stop an infinite piece. If virtual, it does not add any contents to the timeline */
+	virtual?: boolean
+
+	/** Whether the piece affects the output of the Studio or is describing an invisible state within the Studio */
+	notInVision?: boolean
+}
+
+/** The Rundown piece sent from Core */
+export interface IBlueprintRundownPieceDB<TPrivateData = unknown, TPublicData = unknown>
+	extends IBlueprintRundownPiece<TPrivateData, TPublicData> {
+	_id: string
+}