Add option to upload and ingest ingestData from snapshot (SOFIE-3553)

meteor/client/ui/Settings/SnapshotsView.tsx

@@ -74,7 +74,7 @@ const SnapshotsViewContent = withTranslation()(
 			}
 		}
 
-		onUploadFile(e: React.ChangeEvent<HTMLInputElement>, restoreDebugData: boolean) {
+		onUploadFile(e: React.ChangeEvent<HTMLInputElement>, restoreVariant?: 'debug' | 'ingest') {
 			const { t } = this.props
 
 			const file = e.target.files?.[0]
@@ -101,7 +101,8 @@ const SnapshotsViewContent = withTranslation()(
 							body: uploadFileContents,
 							headers: {
 								'content-type': 'application/json',
-								'restore-debug-data': restoreDebugData ? '1' : '0',
+								'restore-debug-data': restoreVariant === 'debug' ? '1' : '0',
+								'ingest-snapshot-data': restoreVariant === 'ingest' ? '1' : '0',
 							},
 						})
 							.then(() => {
@@ -137,6 +138,7 @@ const SnapshotsViewContent = withTranslation()(
 
 			reader.readAsText(file)
 		}
+
 		restoreStoredSnapshot = (snapshotId: SnapshotId) => {
 			const snapshot = Snapshots.findOne(snapshotId)
 			if (snapshot) {
@@ -313,24 +315,48 @@ const SnapshotsViewContent = withTranslation()(
 						</div>
 						<h2 className="mhn">{t('Restore from Snapshot File')}</h2>
 						<div className="mdi">
-							<UploadButton
-								accept="application/json,.json"
-								className="btn btn-secondary"
-								onChange={(e) => this.onUploadFile(e, false)}
-								key={this.state.uploadFileKey}
-							>
-								<FontAwesomeIcon icon={faUpload} />
-								<span>{t('Upload Snapshot')}</span>
-							</UploadButton>
-							<UploadButton
-								accept="application/json,.json"
-								className="btn btn-secondary mls"
-								onChange={(e) => this.onUploadFile(e, true)}
-								key={this.state.uploadFileKey2}
-							>
-								<FontAwesomeIcon icon={faUpload} />
-								<span>{t('Upload Snapshot (for debugging)')}</span>
-							</UploadButton>
+							<p className="mhn">
+								<UploadButton
+									accept="application/json,.json"
+									className="btn btn-secondary"
+									onChange={(e) => this.onUploadFile(e)}
+									key={this.state.uploadFileKey}
+								>
+									<FontAwesomeIcon icon={faUpload} />
+									<span>{t('Upload Snapshot')}</span>
+								</UploadButton>
+								<span className="text-s vsubtle mls">{t('Upload a snapshot file')}</span>
+							</p>
+							<p className="mhn">
+								<UploadButton
+									accept="application/json,.json"
+									className="btn btn-secondary"
+									onChange={(e) => this.onUploadFile(e, 'debug')}
+									key={this.state.uploadFileKey2}
+								>
+									<FontAwesomeIcon icon={faUpload} />
+									<span>{t('Upload Snapshot (for debugging)')}</span>
+								</UploadButton>
+								<span className="text-s vsubtle mls">
+									{t(
+										'Upload a snapshot file (restores additional info not directly related to a Playlist / Rundown, such as Packages, PackageWorkStatuses etc'
+									)}
+								</span>
+							</p>
+							<p className="mhn">
+								<UploadButton
+									accept="application/json,.json"
+									className="btn btn-secondary"
+									onChange={(e) => this.onUploadFile(e, 'ingest')}
+									key={this.state.uploadFileKey2}
+								>
+									<FontAwesomeIcon icon={faUpload} />
+									<span>{t('Ingest from Snapshot')}</span>
+								</UploadButton>
+								<span className="text-s vsubtle mls">
+									{t('Reads the ingest (NRCS) data, and pipes it throught the blueprints')}
+								</span>
+							</p>
 						</div>
 						<h2 className="mhn">{t('Restore from Stored Snapshots')}</h2>
 						<div>

meteor/server/api/snapshot.ts

@@ -489,6 +489,7 @@
 
 	return readSnapshot
 }
+
 async function restoreFromSnapshot(
 	/** The snapshot data to restore */
 	snapshot: AnySnapshot,
@@ -497,22 +498,7 @@
 ): Promise<void> {
 	// Determine what kind of snapshot
 
-	if (!_.isObject(snapshot)) throw new Meteor.Error(500, `Restore input data is not an object`)
-	// First, some special (debugging) cases:
-	// @ts-expect-error is's not really a snapshot here:
-	if (snapshot.externalId && snapshot.segments && snapshot.type === 'mos') {
-		// Special: Not a snapshot, but a datadump of a MOS rundown
-		const studioId: StudioId = Meteor.settings.manualSnapshotIngestStudioId || 'studio0'
-		const studioExists = await checkStudioExists(studioId)
-		if (studioExists) {
-			await importIngestRundown(studioId, snapshot as unknown as IngestRundown)
-			return
-		}
-		throw new Meteor.Error(500, `No Studio found`)
-	}
-
 	// Then, continue as if it's a normal snapshot:
-
 	if (!snapshot.snapshot) throw new Meteor.Error(500, `Restore input data is not a snapshot (${_.keys(snapshot)})`)
 
 	if (snapshot.snapshot.type === SnapshotType.RUNDOWNPLAYLIST) {
@@ -525,11 +511,7 @@
 			)
 		}
 
-		// TODO: Improve this. This matches the 'old' behaviour
-		const studios = await Studios.findFetchAsync({})
-		const snapshotStudioExists = studios.find((studio) => studio._id === playlistSnapshot.playlist.studioId)
-		const studioId = snapshotStudioExists ? playlistSnapshot.playlist.studioId : studios[0]?._id
-		if (!studioId) throw new Meteor.Error(500, `No Studio found`)
+		const studioId = await getStudioIdFromPlaylistSnapshot(playlistSnapshot)
 
 		// A snapshot of a rundownPlaylist
 		return restoreFromRundownPlaylistSnapshot(snapshot as RundownPlaylistSnapshot, studioId, restoreDebugData)
@@ -541,6 +523,60 @@
 	}
 }
 
+async function getStudioIdFromPlaylistSnapshot(playlistSnapshot: RundownPlaylistSnapshot): Promise<StudioId> {
+	// TODO: Improve this. This matches the 'old' behaviour
+	const studios = await Studios.findFetchAsync({})
+	const snapshotStudioExists = studios.find((studio) => studio._id === playlistSnapshot.playlist.studioId)
+	const studioId = snapshotStudioExists ? playlistSnapshot.playlist.studioId : studios[0]?._id
+	if (!studioId) throw new Meteor.Error(500, `No Studio found`)
+	return studioId
+}
+/** Read the ingest data from a snapshot and pipe it into blueprints */
+async function ingestFromSnapshot(
+	/** The snapshot data to restore */
+	snapshot: AnySnapshot
+): Promise<void> {
+	// Determine what kind of snapshot
+	if (!snapshot.snapshot) throw new Meteor.Error(500, `Restore input data is not a snapshot (${_.keys(snapshot)})`)
+	if (snapshot.snapshot.type === SnapshotType.RUNDOWNPLAYLIST) {
+		const playlistSnapshot = snapshot as RundownPlaylistSnapshot
+
+		const studioId = await getStudioIdFromPlaylistSnapshot(playlistSnapshot)
+
+		// Read the ingestData from the snapshot
+		const ingestData = playlistSnapshot.ingestData
+
+		const rundownData = ingestData.filter((e) => e.type === 'rundown')
+		const segmentData = ingestData.filter((e) => e.type === 'segment')
+		const partData = ingestData.filter((e) => e.type === 'part')
+
+		if (rundownData.length === 0) throw new Meteor.Error(402, `No rundowns found in ingestData`)
+
+		for (const seg of segmentData) {
+			seg.data.parts = partData
+				.filter((e) => e.segmentId === seg.segmentId)
+				.map((e) => e.data)
+				.sort((a, b) => b.rank - a.rank)
+		}
+
+		for (let i = 0; i < rundownData.length; i++) {
+			const rundown = rundownData[i]
+
+			const segmentsInRundown = segmentData.filter((e) => e.rundownId === rundown.rundownId)
+
+			const ingestRundown: IngestRundown = rundown.data
+			ingestRundown.segments = segmentsInRundown.map((s) => s.data).sort((a, b) => b.rank - a.rank)
+
+			await importIngestRundown(studioId, ingestRundown)
+		}
+	} else {
+		throw new Meteor.Error(
+			402,
+			`Unable to ingest a snapshot of type "${snapshot.snapshot.type}", did you mean to restore it?`
+		)
+	}
+}
+
 async function restoreFromRundownPlaylistSnapshot(
 	snapshot: RundownPlaylistSnapshot,
 	studioId: StudioId,
@@ -816,8 +852,16 @@
 				if (!snapshot) throw new Meteor.Error(400, 'Restore Snapshot: Missing request body')
 
 				const restoreDebugData = ctx.headers['restore-debug-data'] === '1'
+				const ingestSnapshotData = ctx.headers['ingest-snapshot-data'] === '1'
+
+				if (typeof snapshot !== 'object' || snapshot === null)
+					throw new Meteor.Error(500, `Restore input data is not an object`)
 
-				await restoreFromSnapshot(snapshot, restoreDebugData)
+				if (ingestSnapshotData) {
+					await ingestFromSnapshot(snapshot)
+				} else {
+					await restoreFromSnapshot(snapshot, restoreDebugData)
+				}
 
 				ctx.response.status = 200
 				ctx.response.body = content