feat: Ingest API

meteor/.meteor/packages

@@ -20,3 +20,4 @@ [email protected] # Enable TypeScript syntax in .ts and .tsx modules
 [email protected] # Meteor's client-side reactive programming library
 
 zodern:types
+fetch

meteor/__mocks__/_setupMocks.ts

@@ -10,6 +10,7 @@ jest.mock('nanoid', (...args) => require('./random').setup(args), { virtual: tru
 
 // Add references to all "meteor" mocks below, so that jest resolves the imports properly.
 
+jest.mock('meteor/fetch', () => null, { virtual: true })
 jest.mock('meteor/meteor', (...args) => require('./meteor').setup(args), { virtual: true })
 jest.mock('meteor/random', (...args) => require('./random').setup(args), { virtual: true })
 jest.mock('meteor/check', (...args) => require('./check').setup(args), { virtual: true })

meteor/server/api/ingest/actions.ts

@@ -7,6 +7,8 @@ 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 { fetch } from 'meteor/fetch'
+import { logger } from '../../logging'
 
 /*
 This file contains actions that can be performed on an ingest-device
@@ -27,6 +29,28 @@ export namespace IngestActions {
 
 				return TriggerReloadDataResponse.COMPLETED
 			}
+			case 'httpIngest': {
+				const resyncUrl = rundown.source.resyncUrl
+				fetch(resyncUrl, { method: 'POST' })
+					.then(() => {
+						logger.info(`Reload rundown: resync request sent to "${resyncUrl}"`)
+					})
+					.catch((error) => {
+						if (error.errno === 'ECONNREFUSED') {
+							logger.error(
+								`Reload rundown: could not establish connection with "${resyncUrl}" (ECONNREFUSED)`
+							)
+							return
+						}
+						logger.error(
+							`Reload rundown: error occured while sending resync request to "${resyncUrl}", error: "${JSON.stringify(
+								error
+							)}"`
+						)
+					})
+
+				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)