wip: create and propogate pieceinstances

Author: Julusian

packages/job-worker/src/playout/infinites.ts

@@ -2,7 +2,7 @@ import { PartInstanceId, RundownId, ShowStyleBaseId } from '@sofie-automation/co
 import { DBPart } from '@sofie-automation/corelib/dist/dataModel/Part'
 import { DBPartInstance } from '@sofie-automation/corelib/dist/dataModel/PartInstance'
 import { Piece } from '@sofie-automation/corelib/dist/dataModel/Piece'
-import { PieceInstance } from '@sofie-automation/corelib/dist/dataModel/PieceInstance'
+import { PieceInstance, wrapPieceToInstance } from '@sofie-automation/corelib/dist/dataModel/PieceInstance'
 import {
 	getPieceInstancesForPart as libgetPieceInstancesForPart,
 	getPlayheadTrackingInfinitesForPart as libgetPlayheadTrackingInfinitesForPart,
@@ -16,7 +16,7 @@ import { PlayoutModel } from './model/PlayoutModel'
 import { PlayoutPartInstanceModel } from './model/PlayoutPartInstanceModel'
 import { PlayoutSegmentModel } from './model/PlayoutSegmentModel'
 import { getCurrentTime } from '../lib'
-import { flatten } from '@sofie-automation/corelib/dist/lib'
+import { clone, flatten, getRandomId } from '@sofie-automation/corelib/dist/lib'
 import _ = require('underscore')
 import { IngestModelReadonly } from '../ingest/model/IngestModel'
 import { SegmentOrphanedReason } from '@sofie-automation/corelib/dist/dataModel/Segment'
@@ -282,6 +282,16 @@ export async function syncPlayheadInfinitesForNextPartInstance(
 		)
 
 		toPartInstance.replaceInfinitesFromPreviousPlayhead(infinites)
+	} else if (toPartInstance && !fromPartInstance) {
+		// This is the first take of the rundown, ensure the baseline infinites are loaded
+		const baselineInfinites = await getBaselineInfinitesForPart(
+			context,
+			playoutModel,
+			toPartInstance.partInstance.part,
+			toPartInstance.partInstance._id
+		)
+
+		toPartInstance.replaceInfinitesFromPreviousPlayhead(baselineInfinites)
 	}
 	if (span) span.end()
 }
@@ -377,3 +387,35 @@ export function getPieceInstancesForPart(
 	if (span) span.end()
 	return res
 }
+
+export async function getBaselineInfinitesForPart(
+	context: JobContext,
+	playoutModel: PlayoutModel,
+	// unsavedIngestModel: Pick<IngestModelReadonly, 'rundownId' | 'getAllPieces'> | undefined,
+	part: ReadonlyDeep<DBPart>,
+	partInstanceId: PartInstanceId
+): Promise<PieceInstance[]> {
+	// nocommit - will this ever need to consider an unsaved ingest model?
+
+	// Find the pieces
+	const pieces = await context.directCollections.Pieces.findFetch({
+		startRundownId: part.rundownId,
+		startPartId: null,
+	})
+
+	const playlistActivationId = playoutModel.playlist.activationId
+	if (!playlistActivationId) throw new Error(`RundownPlaylist "${playoutModel.playlistId}" is not active`)
+
+	return pieces.map((piece) => {
+		const instance = wrapPieceToInstance(clone<Piece>(piece), playlistActivationId, partInstanceId, false)
+
+		instance.infinite = {
+			infiniteInstanceId: getRandomId(),
+			infiniteInstanceIndex: 0,
+			infinitePieceId: instance.piece._id,
+			fromPreviousPart: true,
+		}
+
+		return instance
+	})
+}

packages/job-worker/src/playout/setNext.ts

@@ -8,6 +8,7 @@ import { PlayoutPartInstanceModel } from './model/PlayoutPartInstanceModel'
 import { PlayoutSegmentModel } from './model/PlayoutSegmentModel'
 import {
 	fetchPiecesThatMayBeActiveForPart,
+	getBaselineInfinitesForPart,
 	getPieceInstancesForPart,
 	syncPlayheadInfinitesForNextPartInstance,
 } from './infinites'
@@ -288,6 +289,8 @@ async function preparePartInstanceForPartBeingNexted(
 	const rundown = playoutModel.getRundown(nextPart.rundownId)
 	if (!rundown) throw new Error(`Could not find rundown ${nextPart.rundownId}`)
 
+	const partInstanceId = protectString('') // Replaced inside playoutModel.createInstanceForPart
+
 	const possiblePieces = await fetchPiecesThatMayBeActiveForPart(context, playoutModel, undefined, nextPart)
 	const newPieceInstances = getPieceInstancesForPart(
 		context,
@@ -296,9 +299,15 @@ async function preparePartInstanceForPartBeingNexted(
 		rundown,
 		nextPart,
 		possiblePieces,
-		protectString('') // Replaced inside playoutModel.createInstanceForPart
+		partInstanceId
 	)
 
+	if (currentPartInstance === null) {
+		// This is the first take of the rundown, ensure the baseline infinites are loaded
+		const baselineInfinites = await getBaselineInfinitesForPart(context, playoutModel, nextPart, partInstanceId)
+		newPieceInstances.push(...baselineInfinites)
+	}
+
 	return playoutModel.createInstanceForPart(nextPart, newPieceInstances)
 }