session-remove.test.ts 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  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. commit: () => Effect.void,
  22. }),
  23. )
  24. const it = testEffect(
  25. AppNodeBuilder.build(
  26. LayerNode.group([Database.node, Bus.node, SessionProjector.node, SessionStore.node, Session.node]),
  27. [
  28. [Project.node, projects],
  29. [SessionExecution.node, SessionExecution.noopLayer],
  30. ],
  31. ),
  32. )
  33. const location = Location.Ref.make({ directory: AbsolutePath.make("/project") })
  34. describe("Session.remove", () => {
  35. it.effect("removes a session and its children", () =>
  36. Effect.gen(function* () {
  37. const session = yield* Session.Service
  38. const parent = yield* session.create({ location })
  39. const child = yield* session.create({ parentID: parent.id })
  40. yield* session.remove(parent.id)
  41. expect((yield* session.list()).data).toEqual([])
  42. expect(yield* Effect.result(session.get(parent.id))).toMatchObject({ _tag: "Failure" })
  43. expect(yield* Effect.result(session.get(child.id))).toMatchObject({ _tag: "Failure" })
  44. }),
  45. )
  46. it.effect("fails when the session does not exist", () =>
  47. Effect.gen(function* () {
  48. const session = yield* Session.Service
  49. const sessionID = Session.ID.make("ses_missing")
  50. expect(yield* Effect.result(session.remove(sessionID))).toMatchObject({
  51. _tag: "Failure",
  52. failure: { _tag: "Session.NotFoundError", sessionID },
  53. })
  54. }),
  55. )
  56. })