Merge pull request #1623 from tv2norge-collab/contribute/EAV-730

feat: allow custom timeout on TSR actions

Author: ianshade

packages/blueprints-integration/src/context/executeTsrActionContext.ts

@@ -8,6 +8,8 @@ export interface IExecuteTSRActionsContext {
 	executeTSRAction(
 		deviceId: PeripheralDeviceId,
 		actionId: string,
-		payload: Record<string, any>
+		payload: Record<string, any>,
+		/** Timeout for the action, default: 3000 */
+		timeoutMs?: number
 	): Promise<TSR.ActionExecutionResult>
 }

packages/job-worker/src/blueprints/context/OnTakeContext.ts

@@ -163,9 +163,10 @@ export class OnTakeContext extends ShowStyleUserContext implements IOnTakeContex
 	async executeTSRAction(
 		deviceId: PeripheralDeviceId,
 		actionId: string,
-		payload: Record<string, any>
+		payload: Record<string, any>,
+		timeoutMs?: number
 	): Promise<TSR.ActionExecutionResult> {
-		return executePeripheralDeviceAction(this._context, deviceId, null, actionId, payload)
+		return executePeripheralDeviceAction(this._context, deviceId, timeoutMs ?? null, actionId, payload)
 	}
 
 	queuePartAfterTake(rawPart: IBlueprintPart, rawPieces: IBlueprintPiece[]): void {

packages/job-worker/src/blueprints/context/RundownActivationContext.ts

@@ -59,9 +59,10 @@ export class RundownActivationContext extends RundownEventContext implements IRu
 	async executeTSRAction(
 		deviceId: PeripheralDeviceId,
 		actionId: string,
-		payload: Record<string, any>
+		payload: Record<string, any>,
+		timeoutMs?: number
 	): Promise<TSR.ActionExecutionResult> {
-		return executePeripheralDeviceAction(this._context, deviceId, null, actionId, payload)
+		return executePeripheralDeviceAction(this._context, deviceId, timeoutMs ?? null, actionId, payload)
 	}
 
 	async setTimelineDatastoreValue(key: string, value: unknown, mode: DatastorePersistenceMode): Promise<void> {

packages/job-worker/src/blueprints/context/adlibActions.ts

@@ -260,9 +260,10 @@ export class ActionExecutionContext extends ShowStyleUserContext implements IAct
 	async executeTSRAction(
 		deviceId: PeripheralDeviceId,
 		actionId: string,
-		payload: Record<string, any>
+		payload: Record<string, any>,
+		timeoutMs?: number
 	): Promise<TSR.ActionExecutionResult> {
-		return executePeripheralDeviceAction(this._context, deviceId, null, actionId, payload)
+		return executePeripheralDeviceAction(this._context, deviceId, timeoutMs ?? null, actionId, payload)
 	}
 
 	async setTimelineDatastoreValue(key: string, value: unknown, mode: DatastorePersistenceMode): Promise<void> {