feat: Ingest API

meteor/server/api/ingest/actions.ts

@@ -7,6 +7,7 @@ import { PeripheralDeviceType } from '@sofie-automation/corelib/dist/dataModel/P
 import { IngestJobs } from '@sofie-automation/corelib/dist/worker/ingest'
 import { assertNever } from '@sofie-automation/corelib/dist/lib'
 import { VerifiedRundownForUserAction } from '../../security/check'
+import { logger } from '../../logging'
 
 /*
 This file contains actions that can be performed on an ingest-device
@@ -27,6 +28,26 @@ export namespace IngestActions {
 
 				return TriggerReloadDataResponse.COMPLETED
 			}
+			case 'restApi': {
+				const resyncUrl = rundown.source.resyncUrl
+				fetch(resyncUrl, { method: 'POST' })
+					.then(() => {
+						logger.info(`Reload rundown: resync request sent to "${resyncUrl}"`)
+					})
+					.catch((error) => {
+						if (error.cause.code === 'ECONNREFUSED' || error.cause.code === 'ENOTFOUND') {
+							logger.error(
+								`Reload rundown: could not establish connection with "${resyncUrl}" (${error.cause.code})`
+							)
+							return
+						}
+						logger.error(
+							`Reload rundown: error occured while sending resync request to "${resyncUrl}", message: ${error.message}, cause: ${JSON.stringify(error.cause)}`
+						)
+					})
+
+				return TriggerReloadDataResponse.WORKING
+			}
 			case 'testing': {
 				await runIngestOperation(rundown.studioId, IngestJobs.CreateAdlibTestingRundownForShowStyleVariant, {
 					showStyleVariantId: rundown.showStyleVariantId,

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

@@ -19,6 +19,7 @@ import { registerRoutes as registerStudiosRoutes } from './studios'
 import { registerRoutes as registerSystemRoutes } from './system'
 import { registerRoutes as registerBucketsRoutes } from './buckets'
 import { registerRoutes as registerSnapshotRoutes } from './snapshots'
+import { registerRoutes as registerIngestRoutes } from './ingest'
 import { APIFactory, ServerAPIContext } from './types'
 
 function restAPIUserEvent(
@@ -201,3 +202,4 @@ registerStudiosRoutes(sofieAPIRequest)
 registerSystemRoutes(sofieAPIRequest)
 registerBucketsRoutes(sofieAPIRequest)
 registerSnapshotRoutes(sofieAPIRequest)
+registerIngestRoutes(sofieAPIRequest)