Mirror_Repos/anomalyco_opencode
2
0
Fork 0
Code Issues Pull Requests Actions 50 Packages Projects Releases Wiki Activity

refactor(enterprise): use canonical session ids

Browse Source
This commit is contained in:
Kit Langton
2026-08-05 22:08:58 -04:00
parent 2a3242771a
commit 66b3f5965e
1 changed files with 13 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/enterprise/test/core/share.test.ts
+13 -12
View File
@@ -1,11 +1,12 @@
import { describe, expect, test } from "bun:test"
import { descending } from "@opencode-ai/schema/identifier"
import { SessionID } from "@opencode-ai/schema/session-id"
import { Share } from "../../src/core/share"
import { Storage } from "../../src/core/storage"
describe.concurrent("core.share", () => {
test("should create a share", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
expect(share.sessionID).toBe(sessionID)
@@ -15,7 +16,7 @@ describe.concurrent("core.share", () => {
})
test("should remove a share as admin", async () => {
const share = await Share.create({ sessionID: descending() })
const share = await Share.create({ sessionID: SessionID.create() })
await Share.removeAdmin({ id: share.id })
@@ -23,7 +24,7 @@ describe.concurrent("core.share", () => {
})
test("should sync data to a share", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
const data: Share.Data[] = [
@@ -45,7 +46,7 @@ describe.concurrent("core.share", () => {
})
test("should sync multiple batches of data", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
const data1: Share.Data[] = [
@@ -79,7 +80,7 @@ describe.concurrent("core.share", () => {
})
test("should retrieve synced data", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
const data: Share.Data[] = [
@@ -108,7 +109,7 @@ describe.concurrent("core.share", () => {
})
test("should retrieve data from multiple syncs", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
const data1: Share.Data[] = [
@@ -154,7 +155,7 @@ describe.concurrent("core.share", () => {
})
test("should return latest data when syncing duplicate parts", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
const data1: Share.Data[] = [
@@ -192,7 +193,7 @@ describe.concurrent("core.share", () => {
})
test("should return empty array for share with no data", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
const result = await Share.data(share.id)
@@ -203,7 +204,7 @@ describe.concurrent("core.share", () => {
})
test("should migrate legacy event data into the snapshot", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
const data: Share.Data[] = [
{
@@ -225,7 +226,7 @@ describe.concurrent("core.share", () => {
})
test("should throw error for invalid secret", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
const data: Share.Data[] = [
@@ -246,7 +247,7 @@ describe.concurrent("core.share", () => {
})
test("should throw error for non-existent share", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const data: Share.Data[] = [
{
type: "part",
@@ -263,7 +264,7 @@ describe.concurrent("core.share", () => {
})
test("should handle different data types", async () => {
const sessionID = descending()
const sessionID = SessionID.create()
const share = await Share.create({ sessionID })
const data: Share.Data[] = [