Skip to content

Commit b480cc8

Browse files
committed
fix(updateNext): do the flow for no nextPartInstance or oprhaned === 'deleted' first
1 parent 74136f1 commit b480cc8

File tree

1 file changed

+22
-22
lines changed

1 file changed

+22
-22
lines changed

packages/job-worker/src/ingest/updateNext.ts

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,28 @@ export async function ensureNextPartIsValid(context: JobContext, playoutModel: P
4545
const orderedSegments = playoutModel.getAllOrderedSegments()
4646
const orderedParts = playoutModel.getAllOrderedParts()
4747

48-
if (currentPartInstance && nextPartInstance) {
48+
if (!nextPartInstance || nextPartInstance.partInstance.orphaned === 'deleted') {
49+
// Don't have a nextPart or it has been deleted, so autoselect something
50+
const newNextPart = selectNextPart(
51+
context,
52+
playlist,
53+
currentPartInstance?.partInstance ?? null,
54+
nextPartInstance?.partInstance ?? null,
55+
orderedSegments,
56+
orderedParts
57+
)
58+
59+
if (!newNextPart && !playoutModel.playlist.nextPartInfo) {
60+
// No currently nexted part, and nothing was selected, so nothing to update
61+
span?.end()
62+
return false
63+
}
64+
65+
await setNextPart(context, playoutModel, newNextPart ?? null, false)
66+
67+
span?.end()
68+
return true
69+
} else if (currentPartInstance && nextPartInstance) {
4970
// Check if the part is the same
5071
const newNextPart = selectNextPart(
5172
context,
@@ -70,27 +91,6 @@ export async function ensureNextPartIsValid(context: JobContext, playoutModel: P
7091
span?.end()
7192
return true
7293
}
73-
} else if (!nextPartInstance || nextPartInstance.partInstance.orphaned === 'deleted') {
74-
// Don't have a nextPart or it has been deleted, so autoselect something
75-
const newNextPart = selectNextPart(
76-
context,
77-
playlist,
78-
currentPartInstance?.partInstance ?? null,
79-
nextPartInstance?.partInstance ?? null,
80-
orderedSegments,
81-
orderedParts
82-
)
83-
84-
if (!newNextPart && !playoutModel.playlist.nextPartInfo) {
85-
// No currently nexted part, and nothing was selected, so nothing to update
86-
span?.end()
87-
return false
88-
}
89-
90-
await setNextPart(context, playoutModel, newNextPart ?? null, false)
91-
92-
span?.end()
93-
return true
9494
}
9595

9696
span?.end()

0 commit comments

Comments
 (0)