tool-skill.test.ts 6.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. import fs from "fs/promises"
  2. import path from "path"
  3. import { describe, expect } from "bun:test"
  4. import { Effect, Layer } from "effect"
  5. import { FSUtil } from "@opencode-ai/core/fs-util"
  6. import { PermissionV2 } from "@opencode-ai/core/permission"
  7. import { PluginBoot } from "@opencode-ai/core/plugin/boot"
  8. import { AbsolutePath } from "@opencode-ai/core/schema"
  9. import { SessionV2 } from "@opencode-ai/core/session"
  10. import { SkillV2 } from "@opencode-ai/core/skill"
  11. import { SkillTool } from "@opencode-ai/core/tool/skill"
  12. import { ToolOutputStore } from "@opencode-ai/core/tool-output-store"
  13. import { ToolRegistry } from "@opencode-ai/core/tool/registry"
  14. import { tmpdir } from "./fixture/tmpdir"
  15. import { it } from "./lib/effect"
  16. const sessionID = SessionV2.ID.make("ses_skill_tool_test")
  17. describe("SkillTool", () => {
  18. it.live("lists available skills, authorizes the selected name, and loads model-facing content", () =>
  19. Effect.acquireRelease(
  20. Effect.promise(() => tmpdir()),
  21. (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()),
  22. ).pipe(
  23. Effect.flatMap((tmp) =>
  24. Effect.gen(function* () {
  25. const directory = path.join(tmp.path, "effect")
  26. const location = path.join(directory, "SKILL.md")
  27. const reference = path.join(directory, "reference.md")
  28. yield* Effect.promise(() => fs.mkdir(directory, { recursive: true }))
  29. yield* Effect.promise(() =>
  30. Promise.all([fs.writeFile(location, "unused"), fs.writeFile(reference, "reference")]),
  31. )
  32. const info: SkillV2.Info = {
  33. name: "effect",
  34. description: "Use Effect",
  35. location: AbsolutePath.make(location),
  36. content: "# Effect\n\nGuidance",
  37. }
  38. const assertions: PermissionV2.AssertInput[] = []
  39. const truncations: ToolOutputStore.TruncateInput[] = []
  40. let truncate = (input: ToolOutputStore.TruncateInput): Effect.Effect<ToolOutputStore.TruncateResult> =>
  41. Effect.succeed({ content: input.content, truncated: false })
  42. let bootWaited = false
  43. const boot = Layer.succeed(
  44. PluginBoot.Service,
  45. PluginBoot.Service.of({
  46. wait: () =>
  47. Effect.sync(() => {
  48. bootWaited = true
  49. }),
  50. }),
  51. )
  52. const permission = Layer.succeed(
  53. PermissionV2.Service,
  54. PermissionV2.Service.of({
  55. assert: (input) => Effect.sync(() => assertions.push(input)),
  56. ask: () => Effect.die("unused"),
  57. reply: () => Effect.die("unused"),
  58. get: () => Effect.die("unused"),
  59. forSession: () => Effect.die("unused"),
  60. list: () => Effect.die("unused"),
  61. }),
  62. )
  63. const skills = Layer.succeed(
  64. SkillV2.Service,
  65. SkillV2.Service.of({
  66. transform: () => Effect.die("unused"),
  67. sources: () => Effect.die("unused"),
  68. list: () => Effect.succeed([info]),
  69. forAgent: () => Effect.die("unused"),
  70. }),
  71. )
  72. const registry = ToolRegistry.defaultLayer.pipe(Layer.provide(permission))
  73. const resources = Layer.succeed(
  74. ToolOutputStore.Service,
  75. ToolOutputStore.Service.of({
  76. limits: () => Effect.die("unused"),
  77. write: () => Effect.die("unused"),
  78. truncate: (input) => Effect.sync(() => truncations.push(input)).pipe(Effect.andThen(truncate(input))),
  79. read: () => Effect.die("unused"),
  80. cleanup: () => Effect.die("unused"),
  81. }),
  82. )
  83. const tool = SkillTool.layer.pipe(
  84. Layer.provide(registry),
  85. Layer.provide(FSUtil.defaultLayer),
  86. Layer.provide(boot),
  87. Layer.provide(skills),
  88. Layer.provide(resources),
  89. )
  90. const layer = Layer.mergeAll(permission, skills, registry, boot, resources, tool)
  91. return yield* Effect.gen(function* () {
  92. const registry = yield* ToolRegistry.Service
  93. expect(bootWaited).toBe(true)
  94. expect((yield* registry.definitions())[0]).toMatchObject({
  95. name: "skill",
  96. description: expect.stringContaining("**effect**: Use Effect"),
  97. })
  98. expect(
  99. yield* registry.execute({
  100. sessionID,
  101. call: { type: "tool-call", id: "call-skill", name: "skill", input: { name: "effect" } },
  102. }),
  103. ).toEqual({
  104. type: "text",
  105. value: SkillTool.toModelOutput(info, [reference]),
  106. })
  107. expect(truncations).toEqual([
  108. { sessionID, toolCallID: "call-skill", content: SkillTool.toModelOutput(info, [reference]) },
  109. ])
  110. truncate = (input) =>
  111. Effect.succeed({
  112. content: "HEAD\n\n... output truncated; full content available as tool-output://opaque ...\n\nTAIL",
  113. truncated: true,
  114. resource: new ToolOutputStore.Resource({
  115. uri: "tool-output://opaque",
  116. mime: "text/plain",
  117. size: input.content.length,
  118. }),
  119. })
  120. expect(
  121. yield* registry.settle({
  122. sessionID,
  123. call: { type: "tool-call", id: "call-skill-overflow", name: "skill", input: { name: "effect" } },
  124. }),
  125. ).toMatchObject({
  126. result: { type: "text", value: expect.stringContaining("tool-output://opaque") },
  127. output: {
  128. structured: { truncated: true, resource: { uri: "tool-output://opaque" } },
  129. },
  130. })
  131. expect(assertions).toEqual([
  132. { sessionID, action: "skill", resources: ["effect"], save: ["effect"] },
  133. { sessionID, action: "skill", resources: ["effect"], save: ["effect"] },
  134. ])
  135. expect(
  136. yield* registry.execute({
  137. sessionID,
  138. call: { type: "tool-call", id: "call-missing-skill", name: "skill", input: { name: "missing" } },
  139. }),
  140. ).toEqual({ type: "error", value: 'Skill "missing" not found. Available skills: effect' })
  141. }).pipe(Effect.provide(layer))
  142. }),
  143. ),
  144. ),
  145. )
  146. })