mirror of
https://github.com/anomalyco/opencode.git
synced 2026-04-27 00:05:26 +00:00
111 lines
3.2 KiB
TypeScript
111 lines
3.2 KiB
TypeScript
import { afterEach, describe, expect, test } from "bun:test"
|
|
import { Effect } from "effect"
|
|
import { Instance } from "../../src/project/instance"
|
|
import { Session as SessionNs } from "../../src/session"
|
|
import { Log } from "../../src/util/log"
|
|
import { tmpdir } from "../fixture/fixture"
|
|
|
|
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)))
|
|
},
|
|
}
|
|
|
|
afterEach(async () => {
|
|
await Instance.disposeAll()
|
|
})
|
|
|
|
describe("session.list", () => {
|
|
test("filters by directory", async () => {
|
|
await using tmp = await tmpdir({ git: true })
|
|
await Instance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => {
|
|
const first = await svc.create({})
|
|
|
|
await using other = await tmpdir({ git: true })
|
|
const second = await Instance.provide({
|
|
directory: other.path,
|
|
fn: async () => svc.create({}),
|
|
})
|
|
|
|
const sessions = [...svc.list({ directory: tmp.path })]
|
|
const ids = sessions.map((s) => s.id)
|
|
|
|
expect(ids).toContain(first.id)
|
|
expect(ids).not.toContain(second.id)
|
|
},
|
|
})
|
|
})
|
|
|
|
test("filters root sessions", async () => {
|
|
await using tmp = await tmpdir({ git: true })
|
|
await Instance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => {
|
|
const root = await svc.create({ title: "root-session" })
|
|
const child = await svc.create({ title: "child-session", parentID: root.id })
|
|
|
|
const sessions = [...svc.list({ roots: true })]
|
|
const ids = sessions.map((s) => s.id)
|
|
|
|
expect(ids).toContain(root.id)
|
|
expect(ids).not.toContain(child.id)
|
|
},
|
|
})
|
|
})
|
|
|
|
test("filters by start time", async () => {
|
|
await using tmp = await tmpdir({ git: true })
|
|
await Instance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => {
|
|
const session = await svc.create({ title: "new-session" })
|
|
const futureStart = Date.now() + 86400000
|
|
|
|
const sessions = [...svc.list({ start: futureStart })]
|
|
expect(sessions.length).toBe(0)
|
|
},
|
|
})
|
|
})
|
|
|
|
test("filters by search term", async () => {
|
|
await using tmp = await tmpdir({ git: true })
|
|
await Instance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => {
|
|
await svc.create({ title: "unique-search-term-abc" })
|
|
await svc.create({ title: "other-session-xyz" })
|
|
|
|
const sessions = [...svc.list({ search: "unique-search" })]
|
|
const titles = sessions.map((s) => s.title)
|
|
|
|
expect(titles).toContain("unique-search-term-abc")
|
|
expect(titles).not.toContain("other-session-xyz")
|
|
},
|
|
})
|
|
})
|
|
|
|
test("respects limit parameter", async () => {
|
|
await using tmp = await tmpdir({ git: true })
|
|
await Instance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => {
|
|
await svc.create({ title: "session-1" })
|
|
await svc.create({ title: "session-2" })
|
|
await svc.create({ title: "session-3" })
|
|
|
|
const sessions = [...svc.list({ limit: 2 })]
|
|
expect(sessions.length).toBe(2)
|
|
},
|
|
})
|
|
})
|
|
})
|