diff options
| author | Dax Raad <[email protected]> | 2025-12-01 16:46:57 -0500 |
|---|---|---|
| committer | Dax Raad <[email protected]> | 2025-12-01 16:46:57 -0500 |
| commit | 4acb645f04aacf0d8bad8ea526e6ba895d123d57 (patch) | |
| tree | f7a27ffbd2acf7bfd7081e310b87f1ea88261c51 /packages/enterprise | |
| parent | ef664039ac2101ab9774d9d3e9070a147883c4a3 (diff) | |
| download | opencode-4acb645f04aacf0d8bad8ea526e6ba895d123d57.tar.gz opencode-4acb645f04aacf0d8bad8ea526e6ba895d123d57.zip | |
core: add debug logging to troubleshoot share compaction loading
Diffstat (limited to 'packages/enterprise')
| -rw-r--r-- | packages/enterprise/src/core/share.ts | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/packages/enterprise/src/core/share.ts b/packages/enterprise/src/core/share.ts index bf10c4a14..46b277d12 100644 --- a/packages/enterprise/src/core/share.ts +++ b/packages/enterprise/src/core/share.ts @@ -85,16 +85,19 @@ export namespace Share { } export async function data(shareID: string) { + console.log("reading compaction") const compaction: Compaction = (await Storage.read<Compaction>(["share_compaction", shareID])) ?? { data: [], event: undefined, } - + console.log("reading pending events") const list = await Storage.list({ prefix: ["share_event", shareID], end: compaction.event, }).then((x) => x.toReversed()) + console.log("compacting", list.length) + const data = await Promise.all(list.map(async (event) => await Storage.read<Data[]>(event))).then((x) => x.flat()) for (const item of data) { if (!item) continue |
