Skip to content

Commit 8f0153e

Browse files
author
Mint de Wit
committed
feat: move next part should respect quickloop bounds
1 parent 8a10914 commit 8f0153e

File tree

16 files changed

+193
-34
lines changed

16 files changed

+193
-34
lines changed

‎meteor/server/api/userActions.ts‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -191,7 +191,8 @@ class ServerUserActionAPI
191191
eventTime: Time,
192192
rundownPlaylistId: RundownPlaylistId,
193193
partDelta: number,
194-
segmentDelta: number
194+
segmentDelta: number,
195+
ignoreQuickLoop: boolean | null
195196
) {
196197
return ServerClientAPI.runUserActionInLogForPlaylistOnWorker(
197198
this,
@@ -208,6 +209,7 @@ class ServerUserActionAPI
208209
playlistId: rundownPlaylistId,
209210
partDelta: partDelta,
210211
segmentDelta: segmentDelta,
212+
ignoreQuickLoop: ignoreQuickLoop ?? undefined,
211213
}
212214
)
213215
}

‎packages/blueprints-integration/src/context/adlibActionContext.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ export interface IActionExecutionContext
3131
// getNextShowStyleConfig(): Readonly<{ [key: string]: ConfigItemValue }>
3232

3333
/** Move the next part through the rundown. Can move by either a number of parts, or segments in either direction. */
34-
moveNextPart(partDelta: number, segmentDelta: number): Promise<void>
34+
moveNextPart(partDelta: number, segmentDelta: number, ignoreQuickloop?: boolean): Promise<void>
3535
/** Set flag to perform take after executing the current action. Returns state of the flag after each call. */
3636
takeAfterExecuteAction(take: boolean): Promise<boolean>
3737
/** Inform core that a take out of the current partinstance should be blocked until the specified time */

‎packages/blueprints-integration/src/context/onSetAsNextContext.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,5 +76,5 @@ export interface IOnSetAsNextContext extends IShowStyleUserContext, IEventContex
7676
* Multiple calls of this inside one call to `onSetAsNext` will replace earlier calls.
7777
* @returns Whether a new Part was found using the provided offset
7878
*/
79-
moveNextPart(partDelta: number, segmentDelta: number): Promise<boolean>
79+
moveNextPart(partDelta: number, segmentDelta: number, ignoreQuickLoop?: boolean): Promise<boolean>
8080
}

‎packages/blueprints-integration/src/triggers.ts‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -230,6 +230,13 @@ export interface IMoveNextAction extends ITriggeredActionBase {
230230
* @memberof IMoveNextAction
231231
*/
232232
parts: number
233+
/**
234+
* When moving the next part it should ignore any of the boundaries set by the QuickLoop feature
235+
*
236+
* @type {boolean}
237+
* @memberof IMoveNextAction
238+
*/
239+
ignoreQuickLoop: boolean
233240
}
234241

235242
export interface ICreateSnapshotForDebugAction extends ITriggeredActionBase {

‎packages/corelib/src/worker/studio.ts‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -231,6 +231,7 @@ export interface StopPiecesOnSourceLayersProps extends RundownPlayoutPropsBase {
231231
export interface MoveNextPartProps extends RundownPlayoutPropsBase {
232232
partDelta: number
233233
segmentDelta: number
234+
ignoreQuickLoop?: boolean
234235
}
235236
export type ActivateHoldProps = RundownPlayoutPropsBase
236237
export type DeactivateHoldProps = RundownPlayoutPropsBase

‎packages/job-worker/src/blueprints/context/OnSetAsNextContext.ts‎

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ export class OnSetAsNextContext
121121
return this.partAndPieceInstanceService.removePieceInstances('next', pieceInstanceIds)
122122
}
123123

124-
async moveNextPart(partDelta: number, segmentDelta: number): Promise<boolean> {
124+
async moveNextPart(partDelta: number, segmentDelta: number, ignoreQuickLoop?: boolean): Promise<boolean> {
125125
if (typeof partDelta !== 'number') throw new Error('partDelta must be a number')
126126
if (typeof segmentDelta !== 'number') throw new Error('segmentDelta must be a number')
127127

@@ -132,7 +132,13 @@ export class OnSetAsNextContext
132132
}
133133

134134
this.pendingMoveNextPart = {
135-
selectedPart: selectNewPartWithOffsets(this.jobContext, this.playoutModel, partDelta, segmentDelta),
135+
selectedPart: selectNewPartWithOffsets(
136+
this.jobContext,
137+
this.playoutModel,
138+
partDelta,
139+
segmentDelta,
140+
ignoreQuickLoop
141+
),
136142
}
137143

138144
return !!this.pendingMoveNextPart.selectedPart

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

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -157,8 +157,14 @@ export class ActionExecutionContext extends ShowStyleUserContext implements IAct
157157
return this.partAndPieceInstanceService.queuePart(rawPart, rawPieces)
158158
}
159159

160-
async moveNextPart(partDelta: number, segmentDelta: number): Promise<void> {
161-
const selectedPart = selectNewPartWithOffsets(this._context, this._playoutModel, partDelta, segmentDelta)
160+
async moveNextPart(partDelta: number, segmentDelta: number, ignoreQuickloop?: boolean): Promise<void> {
161+
const selectedPart = selectNewPartWithOffsets(
162+
this._context,
163+
this._playoutModel,
164+
partDelta,
165+
segmentDelta,
166+
ignoreQuickloop
167+
)
162168
if (selectedPart) await setNextPartFromPart(this._context, this._playoutModel, selectedPart, true)
163169
}
164170

‎packages/job-worker/src/playout/model/PlayoutModel.ts‎

Lines changed: 19 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -167,6 +167,25 @@ export interface PlayoutModelReadonly extends StudioPlayoutModelBaseReadonly {
167167
*/
168168
getRundownIds(): RundownId[]
169169

170+
/**
171+
* Returns any segmentId's that are found between 2 quickloop markers, none will be returned if
172+
* the end is before the start.
173+
* @param start A quickloop marker
174+
* @param end A quickloop marker
175+
*/
176+
getSegmentsBetweenQuickLoopMarker(start: QuickLoopMarker, end: QuickLoopMarker): SegmentId[]
177+
178+
/**
179+
* Returns any segmentId's that are found between 2 quickloop markers, none will be returned if
180+
* the end is before the start.
181+
* @param start A quickloop marker
182+
* @param end A quickloop marker
183+
*/
184+
getPartsBetweenQuickLoopMarker(
185+
start: QuickLoopMarker,
186+
end: QuickLoopMarker
187+
): { parts: PartId[]; segments: SegmentId[] }
188+
170189
/**
171190
* Search for a PieceInstance in the RundownPlaylist
172191
* @param id Id of the PieceInstance
@@ -345,14 +364,6 @@ export interface PlayoutModel extends PlayoutModelReadonly, StudioPlayoutModelBa
345364
*/
346365
setQuickLoopMarker(type: 'start' | 'end', marker: QuickLoopMarker | null): void
347366

348-
/**
349-
* Returns any segmentId's that are found between 2 quickloop markers, none will be returned if
350-
* the end is before the start.
351-
* @param start A quickloop marker
352-
* @param end A quickloop marker
353-
*/
354-
getSegmentsBetweenQuickLoopMarker(start: QuickLoopMarker, end: QuickLoopMarker): SegmentId[]
355-
356367
calculatePartTimings(
357368
fromPartInstance: PlayoutPartInstanceModel | null,
358369
toPartInstance: PlayoutPartInstanceModel,

‎packages/job-worker/src/playout/model/implementation/PlayoutModelImpl.ts‎

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -240,6 +240,16 @@ export class PlayoutModelReadonlyImpl implements PlayoutModelReadonly {
240240
return undefined
241241
}
242242

243+
getSegmentsBetweenQuickLoopMarker(start: QuickLoopMarker, end: QuickLoopMarker): SegmentId[] {
244+
return this.quickLoopService.getSegmentsBetweenMarkers(start, end)
245+
}
246+
getPartsBetweenQuickLoopMarker(
247+
start: QuickLoopMarker,
248+
end: QuickLoopMarker
249+
): { parts: PartId[]; segments: SegmentId[] } {
250+
return this.quickLoopService.getPartsBetweenMarkers(start, end)
251+
}
252+
243253
#isMultiGatewayMode: boolean | undefined = undefined
244254
public get isMultiGatewayMode(): boolean {
245255
if (this.#isMultiGatewayMode === undefined) {
@@ -830,10 +840,6 @@ export class PlayoutModelImpl extends PlayoutModelReadonlyImpl implements Playou
830840
this.#playlistHasChanged = true
831841
}
832842

833-
getSegmentsBetweenQuickLoopMarker(start: QuickLoopMarker, end: QuickLoopMarker): SegmentId[] {
834-
return this.quickLoopService.getSegmentsBetweenMarkers(start, end)
835-
}
836-
837843
/** Notifications */
838844

839845
async getAllNotifications(

‎packages/job-worker/src/playout/model/services/QuickLoopService.ts‎

Lines changed: 67 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import {
88
import { ForceQuickLoopAutoNext } from '@sofie-automation/shared-lib/dist/core/model/StudioSettings'
99
import { ReadonlyObjectDeep } from 'type-fest/source/readonly-deep'
1010
import { DBPart } from '@sofie-automation/corelib/dist/dataModel/Part'
11-
import { RundownId, SegmentId } from '@sofie-automation/corelib/dist/dataModel/Ids'
11+
import { PartId, RundownId, SegmentId } from '@sofie-automation/corelib/dist/dataModel/Ids'
1212
import { DBSegment } from '@sofie-automation/corelib/dist/dataModel/Segment'
1313
import { PlayoutPartInstanceModel } from '../PlayoutPartInstanceModel'
1414
import { JobContext } from '../../../jobs'
@@ -150,6 +150,7 @@ export class QuickLoopService {
150150
}
151151

152152
getSegmentsBetweenMarkers(startMarker: QuickLoopMarker, endMarker: QuickLoopMarker): SegmentId[] {
153+
// note - this function could be refactored to call getPartsBetweenMarkers instead but it will be less efficient
153154
const segments = this.playoutModel.getAllOrderedSegments()
154155
const segmentIds: SegmentId[] = []
155156

@@ -201,6 +202,71 @@ export class QuickLoopService {
201202
return segmentIds
202203
}
203204

205+
getPartsBetweenMarkers(
206+
startMarker: QuickLoopMarker,
207+
endMarker: QuickLoopMarker
208+
): { parts: PartId[]; segments: SegmentId[] } {
209+
const parts = this.playoutModel.getAllOrderedParts()
210+
const segmentIds: SegmentId[] = []
211+
const partIds: PartId[] = []
212+
213+
let passedStart = false
214+
let seenLastRundown = false
215+
let seenLastSegment = false
216+
217+
for (const p of parts) {
218+
if (
219+
!passedStart &&
220+
((startMarker.type === QuickLoopMarkerType.PART && p._id === startMarker.id) ||
221+
(startMarker.type === QuickLoopMarkerType.SEGMENT && p.segmentId === startMarker.id) ||
222+
(startMarker.type === QuickLoopMarkerType.RUNDOWN && p.rundownId === startMarker.id) ||
223+
startMarker.type === QuickLoopMarkerType.PLAYLIST)
224+
) {
225+
// the start marker is this part, this is the first part in the loop, or this is the first segment that is in the loop
226+
// segments from here on are included in the loop
227+
passedStart = true
228+
}
229+
230+
if (endMarker.type === QuickLoopMarkerType.RUNDOWN) {
231+
// last rundown needs to be inclusive so we need to break once the rundownId is not equal to segment's rundownId
232+
if (p.rundownId === endMarker.id) {
233+
if (!passedStart) {
234+
// we hit the end before the start so quit now:
235+
break
236+
}
237+
seenLastRundown = true
238+
} else if (seenLastRundown) {
239+
// we have passed the last rundown
240+
break
241+
}
242+
} else if (endMarker.type === QuickLoopMarkerType.SEGMENT) {
243+
// last segment needs to be inclusive so we need to break once the segmentId changes but not before
244+
if (p.segmentId === endMarker.id) {
245+
if (!passedStart) {
246+
// we hit the end before the start so quit now:
247+
break
248+
}
249+
seenLastSegment = true
250+
} else if (seenLastSegment) {
251+
// we have passed the last rundown
252+
break
253+
}
254+
}
255+
256+
if (passedStart) {
257+
if (segmentIds.slice(-1)[0] !== p.segmentId) segmentIds.push(p.segmentId)
258+
partIds.push(p._id)
259+
}
260+
261+
if (endMarker.type === QuickLoopMarkerType.PART && p._id === endMarker.id) {
262+
// the endMarker is this part so we can quit now
263+
break
264+
}
265+
}
266+
267+
return { parts: partIds, segments: segmentIds }
268+
}
269+
204270
private areMarkersFlipped(startPosition: MarkerPosition, endPosition: MarkerPosition) {
205271
return compareMarkerPositions(startPosition, endPosition) < 0
206272
}

0 commit comments

Comments
 (0)