session-skill.test.ts 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. import path from "path"
  2. import { describe, expect } from "bun:test"
  3. import { Effect, Layer, LayerMap } from "effect"
  4. import { Database } from "@opencode-ai/core/database/database"
  5. import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
  6. import { LayerNode } from "@opencode-ai/util/effect/layer-node"
  7. import { Bus } from "@opencode-ai/core/bus"
  8. import { Location } from "@opencode-ai/core/location"
  9. import { LocationServiceMap } from "@opencode-ai/core/location-service-map"
  10. import type { LocationServices } from "@opencode-ai/core/location-services"
  11. import { Project } from "@opencode-ai/core/project"
  12. import { AbsolutePath } from "@opencode-ai/core/schema"
  13. import { Session } from "@opencode-ai/core/session"
  14. import { SessionExecution } from "@opencode-ai/core/session/execution"
  15. import { SessionMessage } from "@opencode-ai/core/session/message"
  16. import { SessionProjector } from "@opencode-ai/core/session/projector"
  17. import { SessionStore } from "@opencode-ai/core/session/store"
  18. import { SessionPending } from "@opencode-ai/core/session/pending"
  19. import { Skill } from "@opencode-ai/core/skill"
  20. import { testEffect } from "./lib/effect"
  21. const location = Location.Ref.make({ directory: AbsolutePath.make("/project") })
  22. const projects = Layer.mock(Project.Service, {
  23. resolve: (directory) => Effect.succeed({ id: Project.ID.global, directory, canonical: directory }),
  24. })
  25. const skills = Layer.mock(Skill.Service, {
  26. list: () =>
  27. Effect.succeed([
  28. Skill.Info.make({
  29. id: Skill.ID.make("effect"),
  30. name: Skill.Name.make("Effect"),
  31. description: "Effect guidance",
  32. location: AbsolutePath.make(path.resolve("/skills/effect/SKILL.md")),
  33. content: "Use Effect",
  34. }),
  35. ]),
  36. })
  37. const locations = Layer.effect(
  38. LocationServiceMap.Service,
  39. LayerMap.make(
  40. () =>
  41. // The skill endpoint only needs the location-scoped Skill service.
  42. // oxlint-disable-next-line typescript-eslint/no-unsafe-type-assertion
  43. skills as unknown as Layer.Layer<LocationServices>,
  44. ),
  45. )
  46. const it = testEffect(
  47. AppNodeBuilder.build(
  48. LayerNode.group([Database.node, Bus.node, SessionProjector.node, SessionStore.node, Session.node]),
  49. [
  50. [LocationServiceMap.node, locations],
  51. [Project.node, projects],
  52. [SessionExecution.node, SessionExecution.noopLayer],
  53. ],
  54. ),
  55. )
  56. describe("Session.skill", () => {
  57. it.effect("attaches a resolved skill snapshot to a normal prompt", () =>
  58. Effect.gen(function* () {
  59. const sessions = yield* Session.Service
  60. const database = yield* Database.Service
  61. const bus = yield* Bus.Service
  62. const session = yield* sessions.create({ location })
  63. const id = SessionMessage.ID.make("msg_skill_attachment")
  64. yield* sessions.prompt({
  65. id,
  66. sessionID: session.id,
  67. text: "Apply this guidance",
  68. skills: [{ id: Skill.ID.make("effect"), mention: { start: 20, end: 27, text: "/effect" } }],
  69. resume: false,
  70. })
  71. yield* SessionPending.promote(database.db, bus, session.id, "steer")
  72. expect(yield* sessions.messages({ sessionID: session.id })).toContainEqual(
  73. expect.objectContaining({
  74. id,
  75. type: "user",
  76. text: "Apply this guidance",
  77. skills: [
  78. {
  79. id: "effect",
  80. name: "Effect",
  81. text: expect.stringContaining("Use Effect"),
  82. mention: { start: 20, end: 27, text: "/effect" },
  83. },
  84. ],
  85. }),
  86. )
  87. }),
  88. )
  89. it.effect("projects the caller-supplied message ID", () =>
  90. Effect.gen(function* () {
  91. const sessions = yield* Session.Service
  92. const session = yield* sessions.create({ location })
  93. const id = SessionMessage.ID.make("msg_caller_skill")
  94. yield* sessions.skill({ id, sessionID: session.id, skill: Skill.ID.make("effect"), resume: false })
  95. expect(yield* sessions.messages({ sessionID: session.id })).toContainEqual(
  96. expect.objectContaining({ id, type: "skill", skill: "effect", name: "Effect", text: "Use Effect" }),
  97. )
  98. }),
  99. )
  100. })