summaryrefslogtreecommitdiffhomepage
path: root/packages/enterprise
diff options
context:
space:
mode:
authorDax Raad <[email protected]>2025-12-01 16:46:57 -0500
committerDax Raad <[email protected]>2025-12-01 16:46:57 -0500
commit4acb645f04aacf0d8bad8ea526e6ba895d123d57 (patch)
treef7a27ffbd2acf7bfd7081e310b87f1ea88261c51 /packages/enterprise
parentef664039ac2101ab9774d9d3e9070a147883c4a3 (diff)
downloadopencode-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.ts5
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