Collect all messages via iterateFullHistory (replaces removed getFullHistory).
(service: HistoryService, workspaceId: string)
| 10 | |
| 11 | /** Collect all messages via iterateFullHistory (replaces removed getFullHistory). */ |
| 12 | async function collectFullHistory(service: HistoryService, workspaceId: string) { |
| 13 | const messages: MuxMessage[] = []; |
| 14 | const result = await service.iterateFullHistory(workspaceId, "forward", (chunk) => { |
| 15 | messages.push(...chunk); |
| 16 | }); |
| 17 | assert(result.success, `collectFullHistory failed: ${result.success ? "" : result.error}`); |
| 18 | return messages; |
| 19 | } |
| 20 | |
| 21 | async function writeHistoryLines( |
| 22 | config: Config, |
no test coverage detected