wip: remove broken debug method

Author: Julusian

meteor/server/api/ingest/debug.ts

@@ -8,7 +8,6 @@ import { QueueStudioJob } from '../../worker/worker'
 import { StudioJobs } from '@sofie-automation/corelib/dist/worker/studio'
 import { RundownPlaylistId, SegmentId } from '@sofie-automation/corelib/dist/dataModel/Ids'
 import { MeteorDebugMethods } from '../../methods'
-import { DBRundown } from '@sofie-automation/corelib/dist/dataModel/Rundown'
 
 MeteorDebugMethods({
 	/**
@@ -47,31 +46,4 @@ MeteorDebugMethods({
 			segmentExternalId: segment.externalId,
 		})
 	},
-	/**
-	 * Regenerate all the expected packages for all rundowns in the system.
-	 * Additionally it will recreate any expectedMediaItems and expectedPlayoutItems.
-	 * This shouldn't be necessary as ingest will do this for each rundown as part of its workflow
-	 */
-	debug_recreateExpectedPackages: async () => {
-		const rundowns = (await Rundowns.findFetchAsync(
-			{},
-			{
-				projection: {
-					_id: 1,
-					studioId: 1,
-					source: 1,
-				},
-			}
-		)) as Array<Pick<DBRundown, '_id' | 'studioId' | 'source'>>
-
-		await Promise.all(
-			rundowns
-				.filter((rundown) => rundown.source.type !== 'snapshot')
-				.map(async (rundown) =>
-					runIngestOperation(rundown.studioId, IngestJobs.ExpectedPackagesRegenerate, {
-						rundownId: rundown._id,
-					})
-				)
-		)
-	},
 })

packages/corelib/src/worker/ingest.ts

@@ -105,10 +105,6 @@ export enum IngestJobs {
 	 */
 	MosSwapStory = 'mosSwapStory',
 
-	/**
-	 * Debug: Regenerate ExpectedPackages for a Rundown
-	 */
-	ExpectedPackagesRegenerate = 'expectedPackagesRegenerate',
 	/**
 	 * Some PackageInfos have been updated, regenerate any Parts which depend on these PackageInfos
 	 */
@@ -230,9 +226,6 @@ export interface MosSwapStoryProps extends IngestPropsBase {
 	story1: MOS.IMOSString128
 }
 
-export interface ExpectedPackagesRegenerateProps {
-	rundownId: RundownId
-}
 export interface PackageInfosUpdatedRundownProps extends IngestPropsBase {
 	packageIds: ExpectedPackageId[]
 }
@@ -313,7 +306,6 @@ export type IngestJobFunc = {
 	[IngestJobs.MosMoveStory]: (data: MosMoveStoryProps) => void
 	[IngestJobs.MosSwapStory]: (data: MosSwapStoryProps) => void
 
-	[IngestJobs.ExpectedPackagesRegenerate]: (data: ExpectedPackagesRegenerateProps) => void
 	[IngestJobs.PackageInfosUpdatedRundown]: (data: PackageInfosUpdatedRundownProps) => void
 
 	[IngestJobs.UserRemoveRundown]: (data: UserRemoveRundownProps) => void

packages/job-worker/src/ingest/model/implementation/SaveIngestModel.ts

@@ -92,10 +92,10 @@ export class SaveIngestModelHelper {
 	}
 }
 
-function transformIngestExpectedPackageToDb(
+async function transformIngestExpectedPackageToDb(
 	context: JobContext,
 	docs: IngestExpectedPackage<any>[]
-): ExpectedPackageDBNew[] {
+): Promise<ExpectedPackageDBNew[]> {
 	return docs.map((doc) => ({
 		...doc,
 		studioId: context.studioId,

packages/job-worker/src/ingest/packageInfo.ts

@@ -1,47 +1,12 @@
 import { ExpectedPackageDBType } from '@sofie-automation/corelib/dist/dataModel/ExpectedPackages'
 import { SegmentId } from '@sofie-automation/corelib/dist/dataModel/Ids'
-import {
-	ExpectedPackagesRegenerateProps,
-	PackageInfosUpdatedRundownProps,
-} from '@sofie-automation/corelib/dist/worker/ingest'
+import { PackageInfosUpdatedRundownProps } from '@sofie-automation/corelib/dist/worker/ingest'
 import { logger } from '../logging'
 import { JobContext } from '../jobs'
 import { regenerateSegmentsFromIngestData } from './generationSegment'
-import { runWithRundownLock } from './lock'
-import {
-	updateExpectedMediaAndPlayoutItemsForPartModel,
-	updateExpectedMediaAndPlayoutItemsForRundownBaseline,
-} from './expectedPackages'
-import { loadIngestModelFromRundown } from './model/implementation/LoadIngestModel'
 import { runCustomIngestUpdateOperation } from './runOperation'
 import { assertNever } from '@sofie-automation/corelib/dist/lib'
 
-/**
- * Debug: Regenerate ExpectedPackages for a Rundown
- */
-export async function handleExpectedPackagesRegenerate(
-	context: JobContext,
-	data: ExpectedPackagesRegenerateProps
-): Promise<void> {
-	return runWithRundownLock(context, data.rundownId, async (rundown, rundownLock) => {
-		if (!rundown) throw new Error(`Rundown "${data.rundownId}" not found`)
-
-		// TODO - this needs to be run inside a playlistLock
-
-		const ingestModel = await loadIngestModelFromRundown(context, rundownLock, rundown)
-
-		// nocommit reimplement this for packages
-
-		for (const part of ingestModel.getAllOrderedParts()) {
-			updateExpectedMediaAndPlayoutItemsForPartModel(context, part)
-		}
-
-		await updateExpectedMediaAndPlayoutItemsForRundownBaseline(context, ingestModel, undefined)
-
-		await ingestModel.saveAllToDatabase(rundownLock as any) // nocommit
-	})
-}
-
 /**
  * Some PackageInfos have been updated, regenerate any Parts which depend on these PackageInfos
  */

packages/job-worker/src/workers/ingest/jobs.ts

@@ -29,7 +29,7 @@ import {
 	handleUpdatedSegment,
 	handleUpdatedSegmentRanks,
 } from '../../ingest/ingestSegmentJobs'
-import { handleExpectedPackagesRegenerate, handleUpdatedPackageInfoForRundown } from '../../ingest/packageInfo'
+import { handleUpdatedPackageInfoForRundown } from '../../ingest/packageInfo'
 import {
 	handleBucketActionModify,
 	handleBucketActionRegenerateExpectedPackages,
@@ -81,7 +81,6 @@ export const ingestJobHandlers: IngestJobHandlers = {
 	[IngestJobs.MosMoveStory]: wrapMosIngestJob(handleMosMoveStories),
 	[IngestJobs.MosSwapStory]: wrapMosIngestJob(handleMosSwapStories),
 
-	[IngestJobs.ExpectedPackagesRegenerate]: handleExpectedPackagesRegenerate,
 	[IngestJobs.PackageInfosUpdatedRundown]: handleUpdatedPackageInfoForRundown,
 
 	[IngestJobs.UserRemoveRundown]: handleUserRemoveRundown,