wip

Author: Julusian

packages/job-worker/src/jobs/index.ts

@@ -25,11 +25,16 @@ export { ProcessedShowStyleVariant, ProcessedShowStyleBase, ProcessedShowStyleCo
 export { JobStudio }
 
 export interface QueueJobOptions {
-	/** Optional: The job will be run with a low priority, allowing other operations to be run first */
+	/** 
+	 * The job should be run with a low priority, allowing other operations to be run first ]
+	 */
 	lowPriority?: boolean
 
-	/** Optional: Debounce execution, if the job is already queued, it will not be queued again */
-	debounce?: boolean
+	/** 
+	 * Debounce execution, delaying execution until at least this wait time.
+	 * If the job is already queued, it will not be queued again 
+	 */
+	debounce?: number
 }
 
 /**

packages/job-worker/src/playout/model/implementation/SavePlayoutModel.ts

@@ -178,8 +178,6 @@ export async function writeExpectedPackagesForPlayoutSources(
 	)) as Pick<ExpectedPackageDB, '_id' | 'playoutSources'>[]
 	const existingPackagesMap = normalizeArrayToMap(existingPackages, '_id')
 
-	// const targetPackages = new Map<ExpectedPackageId, ExpectedPackageEntry>()
-
 	const pieceInstancesToAddToPackages = new Map<ExpectedPackageId, PieceInstanceId[]>()
 	const packagesToInsert = new Map<ExpectedPackageId, ExpectedPackageEntry>()
 
@@ -203,12 +201,14 @@ export async function writeExpectedPackagesForPlayoutSources(
 					pieceInstanceIds.push(pieceInstance.pieceInstance._id)
 					pieceInstancesToAddToPackages.set(packageId, pieceInstanceIds)
 				} else {
-					// Record as needing a new package
+					// Record as needing a new document
 					packagesToInsert.set(packageId, {
 						_id: packageId,
 						package: expectedPackage,
 						pieceInstanceIds: [pieceInstance.pieceInstance._id],
 					})
+
+					// Future: If this came from a bucket, can we copy the packageInfos across to minimise latency until the status is ready?
 				}
 			}
 		}
@@ -256,18 +256,15 @@ export async function writeExpectedPackagesForPlayoutSources(
 	}
 
 	// We can't easily track any references which have been deleted, so we should schedule a cleanup job to deal with that for us
-	await context.queueStudioJob(StudioJobs.CleanupOrphanedExpectedPackageReferences, {
-		playlistId: playlistId,
-		rundownId: rundownId,
-	})
-
-	// TODO: Implement this function
-	/**
-	 * Here we have access to all the PieceInstances for any 'current' partinstances (within the current segment?, and whatever is nexted)
-	 * So we can easily iterate through them all to build out the needed expected packages.
-	 * From there, we can make sure that they are referenced in the database.
-	 *
-	 * We can't track any references which have been deleted, so we probably want to dispatch a job to perform the cleanup on a debounce.
-	 * Timing isnt critical, as this will be stale and unreferenced data (other than it could cause package-manager to do pointless work)
-	 */
+	await context.queueStudioJob(
+		StudioJobs.CleanupOrphanedExpectedPackageReferences,
+		{
+			playlistId: playlistId,
+			rundownId: rundownId,
+		},
+		{
+			lowPriority: true,
+			debounce: 1000,
+		}
+	)
 }