session-remove.test.ts 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. import { describe, expect } from "bun:test"
  2. import { Effect, Layer } from "effect"
  3. import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
  4. import { LayerNode } from "@opencode-ai/util/effect/layer-node"
  5. import { Database } from "@opencode-ai/core/database/database"
  6. import { Bus } from "@opencode-ai/core/bus"
  7. import { Location } from "@opencode-ai/core/location"
  8. import { Project } from "@opencode-ai/core/project"
  9. import { AbsolutePath } from "@opencode-ai/core/schema"
  10. import { Session } from "@opencode-ai/core/session"
  11. import { SessionExecution } from "@opencode-ai/core/session/execution"
  12. import { SessionProjector } from "@opencode-ai/core/session/projector"
  13. import { SessionStore } from "@opencode-ai/core/session/store"
  14. import { testEffect } from "./lib/effect"
  15. const projects = Layer.succeed(
  16. Project.Service,
  17. Project.Service.of({
  18. list: () => Effect.succeed([]),
  19. resolve: (directory) => Effect.succeed({ id: Project.ID.global, directory, canonical: directory }),
  20. directories: () => Effect.succeed([]),
  21. }),
  22. )
  23. const it = testEffect(
  24. AppNodeBuilder.build(
  25. LayerNode.group([Database.node, Bus.node, SessionProjector.node, SessionStore.node, Session.node]),
  26. [
  27. [Project.node, projects],
  28. [SessionExecution.node, SessionExecution.noopLayer],
  29. ],
  30. ),
  31. )
  32. const location = Location.Ref.make({ directory: AbsolutePath.make("/project") })
  33. describe("Session.remove", () => {
  34. it.effect("removes a session and its children", () =>
  35. Effect.gen(function* () {
  36. const session = yield* Session.Service
  37. const parent = yield* session.create({ location })
  38. const child = yield* session.create({ parentID: parent.id })
  39. yield* session.remove(parent.id)
  40. expect((yield* session.list()).data).toEqual([])
  41. expect(yield* Effect.result(session.get(parent.id))).toMatchObject({ _tag: "Failure" })
  42. expect(yield* Effect.result(session.get(child.id))).toMatchObject({ _tag: "Failure" })
  43. }),
  44. )
  45. it.effect("fails when the session does not exist", () =>
  46. Effect.gen(function* () {
  47. const session = yield* Session.Service
  48. const sessionID = Session.ID.make("ses_missing")
  49. expect(yield* Effect.result(session.remove(sessionID))).toMatchObject({
  50. _tag: "Failure",
  51. failure: { _tag: "Session.NotFoundError", sessionID },
  52. })
  53. }),
  54. )
  55. })