message storage performance improvements

2025-11-07 01:11:47 -05:00
parent 0b7c4ec0e6
commit e1e6b9b86f
8 changed files with 28 additions and 32 deletions
@@ -111,9 +111,7 @@ export namespace SessionCompaction {
        draft.time.compacting = undefined
      })
    })
-    const toSummarize = await Session.messages({ sessionID: input.sessionID }).then(
-      MessageV2.filterCompacted,
-    )
+    const toSummarize = await MessageV2.filterCompacted(Session.messageStream(input.sessionID))
    const model = await Provider.getModel(input.providerID, input.modelID)
    const system = [
      ...SystemPrompt.summarize(model.providerID),