|
|
@@ -287,7 +287,9 @@ export namespace SessionCompaction {
|
|
|
})
|
|
|
if (result.shouldRetry) {
|
|
|
for (let retry = 1; retry < maxRetries; retry++) {
|
|
|
- const lastRetryPart = result.parts.findLast((p): p is MessageV2.RetryPart => p.type === "retry")
|
|
|
+ const lastRetryPart = result.parts.findLast(
|
|
|
+ (p): p is MessageV2.RetryPart => p.type === "retry",
|
|
|
+ )
|
|
|
|
|
|
if (lastRetryPart) {
|
|
|
const delayMs = SessionRetry.getRetryDelayInMs(lastRetryPart.error, retry)
|
|
|
@@ -336,7 +338,9 @@ export namespace SessionCompaction {
|
|
|
if (
|
|
|
!msg.error ||
|
|
|
(MessageV2.AbortedError.isInstance(msg.error) &&
|
|
|
- result.parts.some((part): part is MessageV2.TextPart => part.type === "text" && part.text.length > 0))
|
|
|
+ result.parts.some(
|
|
|
+ (part): part is MessageV2.TextPart => part.type === "text" && part.text.length > 0,
|
|
|
+ ))
|
|
|
) {
|
|
|
msg.summary = true
|
|
|
Bus.publish(Event.Compacted, {
|