test(compaction): read latest compaction marker
This commit is contained in:
parent
e0501ac50b
commit
357cdcfcad
1 changed files with 3 additions and 1 deletions
|
|
@ -282,7 +282,9 @@ function createSummaryCompaction(sessionID: SessionID) {
|
||||||
function readCompactionPart(sessionID: SessionID) {
|
function readCompactionPart(sessionID: SessionID) {
|
||||||
return SessionNs.Service.use((ssn) => ssn.messages({ sessionID })).pipe(
|
return SessionNs.Service.use((ssn) => ssn.messages({ sessionID })).pipe(
|
||||||
Effect.map((messages) =>
|
Effect.map((messages) =>
|
||||||
messages.flatMap((message) => message.parts).find((item): item is MessageV2.CompactionPart => item.type === "compaction"),
|
messages
|
||||||
|
.findLast((message) => message.parts.some((item) => item.type === "compaction"))
|
||||||
|
?.parts.find((item): item is MessageV2.CompactionPart => item.type === "compaction"),
|
||||||
),
|
),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue