diff options
| author | Dax Raad <[email protected]> | 2025-12-01 16:35:03 -0500 |
|---|---|---|
| committer | Dax Raad <[email protected]> | 2025-12-01 16:35:07 -0500 |
| commit | 3d99dc78dbff982cde6dd61a0629b7ee9de1a8f3 (patch) | |
| tree | 4c8dabb52db7c26d2d412c1be861f7599168a7d3 /packages/enterprise/test-debug.ts | |
| parent | 95c3a8b80505fcb3140989daf6fece3377aa3b95 (diff) | |
| download | opencode-3d99dc78dbff982cde6dd61a0629b7ee9de1a8f3.tar.gz opencode-3d99dc78dbff982cde6dd61a0629b7ee9de1a8f3.zip | |
core: reduce latency when loading shared sessions through event compaction
Diffstat (limited to 'packages/enterprise/test-debug.ts')
| -rw-r--r-- | packages/enterprise/test-debug.ts | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/packages/enterprise/test-debug.ts b/packages/enterprise/test-debug.ts new file mode 100644 index 000000000..fca995297 --- /dev/null +++ b/packages/enterprise/test-debug.ts @@ -0,0 +1,37 @@ +import { Share } from "./src/core/share" +import { Storage } from "./src/core/storage" + +async function test() { + const shareInfo = await Share.create({ sessionID: "test-debug-" + Date.now() }) + + const batch1: Share.Data[] = [ + { type: "part", data: { id: "part1", sessionID: "session1", messageID: "msg1", type: "text", text: "Hello" } }, + ] + + const batch2: Share.Data[] = [ + { type: "part", data: { id: "part1", sessionID: "session1", messageID: "msg1", type: "text", text: "Hello Updated" } }, + ] + + await Share.sync({ + share: { id: shareInfo.id, secret: shareInfo.secret }, + data: batch1, + }) + + await Share.sync({ + share: { id: shareInfo.id, secret: shareInfo.secret }, + data: batch2, + }) + + const events = await Storage.list({ prefix: ["share_event", shareInfo.id] }) + console.log("Events (raw):", events) + console.log("Events (reversed):", events.toReversed()) + + for (const event of events.toReversed()) { + const data = await Storage.read(event) + console.log("Event data (reversed order):", event, data) + } + + await Share.remove({ id: shareInfo.id, secret: shareInfo.secret }) +} + +test() |
