mirror of
https://github.com/anomalyco/opencode.git
synced 2026-05-19 08:09:51 +00:00
106 lines
3.7 KiB
TypeScript
106 lines
3.7 KiB
TypeScript
import { describe, expect, test } from "bun:test"
|
|
import { Effect } from "effect"
|
|
import z from "zod"
|
|
import { Instance } from "../../src/project/instance"
|
|
import { WithInstance } from "../../src/project/with-instance"
|
|
import { Project } from "@/project/project"
|
|
import { Session as SessionNs } from "@/session/session"
|
|
import * as Log from "@opencode-ai/core/util/log"
|
|
import { tmpdir } from "../fixture/fixture"
|
|
|
|
void Log.init({ print: false })
|
|
|
|
function run<A, E>(fx: Effect.Effect<A, E, SessionNs.Service>) {
|
|
return Effect.runPromise(fx.pipe(Effect.provide(SessionNs.defaultLayer)))
|
|
}
|
|
|
|
const svc = {
|
|
...SessionNs,
|
|
create(input?: SessionNs.CreateInput) {
|
|
return run(SessionNs.Service.use((svc) => svc.create(input)))
|
|
},
|
|
setArchived(input: z.output<typeof SessionNs.SetArchivedInput.zod>) {
|
|
return run(SessionNs.Service.use((svc) => svc.setArchived(input)))
|
|
},
|
|
}
|
|
|
|
describe("session.listGlobal", () => {
|
|
test("lists sessions across projects with project metadata", async () => {
|
|
await using first = await tmpdir({ git: true })
|
|
await using second = await tmpdir({ git: true })
|
|
|
|
const firstSession = await WithInstance.provide({
|
|
directory: first.path,
|
|
fn: async () => svc.create({ title: "first-session" }),
|
|
})
|
|
const secondSession = await WithInstance.provide({
|
|
directory: second.path,
|
|
fn: async () => svc.create({ title: "second-session" }),
|
|
})
|
|
|
|
const sessions = [...svc.listGlobal({ limit: 200 })]
|
|
const ids = sessions.map((session) => session.id)
|
|
|
|
expect(ids).toContain(firstSession.id)
|
|
expect(ids).toContain(secondSession.id)
|
|
|
|
const firstProject = Project.get(firstSession.projectID)
|
|
const secondProject = Project.get(secondSession.projectID)
|
|
|
|
const firstItem = sessions.find((session) => session.id === firstSession.id)
|
|
const secondItem = sessions.find((session) => session.id === secondSession.id)
|
|
|
|
expect(firstItem?.project?.id).toBe(firstProject?.id)
|
|
expect(firstItem?.project?.worktree).toBe(firstProject?.worktree)
|
|
expect(secondItem?.project?.id).toBe(secondProject?.id)
|
|
expect(secondItem?.project?.worktree).toBe(secondProject?.worktree)
|
|
})
|
|
|
|
test("excludes archived sessions by default", async () => {
|
|
await using tmp = await tmpdir({ git: true })
|
|
|
|
const archived = await WithInstance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => svc.create({ title: "archived-session" }),
|
|
})
|
|
|
|
await WithInstance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => svc.setArchived({ sessionID: archived.id, time: Date.now() }),
|
|
})
|
|
|
|
const sessions = [...svc.listGlobal({ limit: 200 })]
|
|
const ids = sessions.map((session) => session.id)
|
|
|
|
expect(ids).not.toContain(archived.id)
|
|
|
|
const allSessions = [...svc.listGlobal({ limit: 200, archived: true })]
|
|
const allIds = allSessions.map((session) => session.id)
|
|
|
|
expect(allIds).toContain(archived.id)
|
|
})
|
|
|
|
test("supports cursor pagination", async () => {
|
|
await using tmp = await tmpdir({ git: true })
|
|
|
|
const first = await WithInstance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => svc.create({ title: "page-one" }),
|
|
})
|
|
await new Promise((resolve) => setTimeout(resolve, 5))
|
|
const second = await WithInstance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => svc.create({ title: "page-two" }),
|
|
})
|
|
|
|
const page = [...svc.listGlobal({ directory: tmp.path, limit: 1 })]
|
|
expect(page.length).toBe(1)
|
|
expect(page[0].id).toBe(second.id)
|
|
|
|
const next = [...svc.listGlobal({ directory: tmp.path, limit: 10, cursor: page[0].time.updated })]
|
|
const ids = next.map((session) => session.id)
|
|
|
|
expect(ids).toContain(first.id)
|
|
expect(ids).not.toContain(second.id)
|
|
})
|
|
})
|