mirror of
https://github.com/anomalyco/opencode.git
synced 2026-09-04 03:24:34 +00:00
Replace exposed layer graph assembly with opaque declarations, checked substitutions, and lifetime-aware compilation. Preserve deep replacement, ordered startup, and Effect-owned resource lifetimes; migrate callers and verify source and published package contracts.
294 lines
11 KiB
TypeScript
294 lines
11 KiB
TypeScript
import fs from "fs/promises"
|
|
import path from "path"
|
|
import { describe, expect, test } from "bun:test"
|
|
import { Effect, Layer, Schema } from "effect"
|
|
import { LayerNode } from "@opencode-ai/util/effect/layer-node"
|
|
import { Location } from "@opencode-ai/core/location"
|
|
import { LocationMutation } from "@opencode-ai/core/location-mutation"
|
|
import { AbsolutePath } from "@opencode-ai/core/schema"
|
|
import { Global } from "@opencode-ai/util/global"
|
|
import { tmpdir } from "./fixture/tmpdir"
|
|
import { location } from "./fixture/location"
|
|
import { it } from "./lib/effect"
|
|
|
|
function provide(directory: string, projectDirectory = directory) {
|
|
return Effect.provide(
|
|
LayerNode.compile(LocationMutation.node, {
|
|
replacements: [
|
|
Location.node.replace(
|
|
Layer.succeed(
|
|
Location.Service,
|
|
Location.Service.of(
|
|
location(
|
|
{ directory: AbsolutePath.make(directory) },
|
|
{ projectDirectory: AbsolutePath.make(projectDirectory) },
|
|
),
|
|
),
|
|
),
|
|
),
|
|
],
|
|
}),
|
|
)
|
|
}
|
|
|
|
function withTmp<A, E, R>(f: (directory: string) => Effect.Effect<A, E, R>) {
|
|
return Effect.acquireRelease(
|
|
Effect.promise(() => tmpdir()),
|
|
(tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()),
|
|
).pipe(Effect.flatMap((tmp) => f(tmp.path)))
|
|
}
|
|
|
|
describe("LocationMutation", () => {
|
|
it.live("resolves an active relative existing file target", () =>
|
|
withTmp((directory) =>
|
|
Effect.gen(function* () {
|
|
const targetPath = path.join(directory, "hello.txt")
|
|
yield* Effect.promise(() => fs.writeFile(targetPath, "hello"))
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: "hello.txt" })
|
|
|
|
expect(target).toMatchObject({
|
|
absolute: targetPath,
|
|
resource: "hello.txt",
|
|
})
|
|
expect(target.externalDirectory).toBeUndefined()
|
|
}).pipe(provide(directory)),
|
|
),
|
|
)
|
|
|
|
it.live("resolves an active relative prospective file target", () =>
|
|
withTmp((directory) =>
|
|
Effect.gen(function* () {
|
|
yield* Effect.promise(() => fs.mkdir(path.join(directory, "src")))
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: path.join("src", "new.txt") })
|
|
expect(target).toMatchObject({
|
|
absolute: path.join(directory, "src", "new.txt"),
|
|
resource: "src/new.txt",
|
|
})
|
|
}).pipe(provide(directory)),
|
|
),
|
|
)
|
|
|
|
it.live("requires external-directory authorization for a relative lexical escape", () =>
|
|
withTmp((directory) =>
|
|
Effect.gen(function* () {
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: "../outside.txt" })
|
|
const root = path.dirname(directory)
|
|
expect(target).toMatchObject({
|
|
absolute: path.join(root, "outside.txt"),
|
|
resource: path.join(root, "outside.txt").replaceAll("\\", "/"),
|
|
})
|
|
expect(target.externalDirectory).toMatchObject({
|
|
directory: root,
|
|
resource: path.join(root, "*").replaceAll("\\", "/"),
|
|
})
|
|
}).pipe(provide(directory)),
|
|
),
|
|
)
|
|
|
|
it.live("allows a relative path outside the Location but inside the project worktree", () =>
|
|
withTmp((directory) =>
|
|
Effect.gen(function* () {
|
|
const active = path.join(directory, "packages", "opencode")
|
|
yield* Effect.promise(() => fs.mkdir(active, { recursive: true }))
|
|
const target = yield* (yield* LocationMutation.Service).resolve({ path: "../../README.md" })
|
|
expect(target).toMatchObject({
|
|
absolute: path.join(directory, "README.md"),
|
|
resource: "../../README.md",
|
|
})
|
|
expect(target.externalDirectory).toBeUndefined()
|
|
}).pipe(provide(path.join(directory, "packages", "opencode"), directory)),
|
|
),
|
|
)
|
|
|
|
it.live("does not treat a filesystem-root project sentinel as an internal boundary", () =>
|
|
withTmp((directory) =>
|
|
Effect.gen(function* () {
|
|
const target = yield* (yield* LocationMutation.Service).resolve({ path: "../outside.txt" })
|
|
expect(target.externalDirectory).toBeDefined()
|
|
}).pipe(provide(directory, path.parse(directory).root)),
|
|
),
|
|
)
|
|
|
|
it.live("resolves a prospective target below an external symlink lexically", () =>
|
|
withTmp((directory) => {
|
|
const outside = `${directory}-outside`
|
|
return Effect.gen(function* () {
|
|
if (process.platform === "win32") return
|
|
yield* Effect.promise(async () => {
|
|
await fs.mkdir(outside)
|
|
await fs.symlink(outside, path.join(directory, "escape"))
|
|
})
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: path.join("escape", "new.txt") })
|
|
expect(target).toMatchObject({
|
|
absolute: path.join(directory, "escape", "new.txt"),
|
|
resource: "escape/new.txt",
|
|
})
|
|
expect(target.externalDirectory).toBeUndefined()
|
|
yield* Effect.promise(() => fs.rm(outside, { recursive: true, force: true }))
|
|
}).pipe(provide(directory))
|
|
}),
|
|
)
|
|
|
|
it.live("follows an in-location symlink using ordinary filesystem semantics", () =>
|
|
withTmp((directory) =>
|
|
Effect.gen(function* () {
|
|
if (process.platform === "win32") return
|
|
yield* Effect.promise(async () => {
|
|
await fs.mkdir(path.join(directory, "actual"))
|
|
await fs.symlink(path.join(directory, "actual"), path.join(directory, "linked"))
|
|
})
|
|
|
|
const mutation = yield* LocationMutation.Service
|
|
expect(yield* mutation.resolve({ path: "linked/new.txt" })).toMatchObject({
|
|
absolute: path.join(directory, "linked", "new.txt"),
|
|
resource: "linked/new.txt",
|
|
})
|
|
}).pipe(provide(directory)),
|
|
),
|
|
)
|
|
|
|
it.live("accepts an explicit absolute in-location target without external approval", () =>
|
|
withTmp((directory) =>
|
|
Effect.gen(function* () {
|
|
const targetPath = path.join(directory, "new.txt")
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: targetPath })
|
|
expect(target).toMatchObject({
|
|
absolute: targetPath,
|
|
resource: "new.txt",
|
|
})
|
|
expect(target.externalDirectory).toBeUndefined()
|
|
}).pipe(provide(directory)),
|
|
),
|
|
)
|
|
|
|
it.live("requires external-directory authorization for an explicit external absolute target", () =>
|
|
withTmp((directory) =>
|
|
withTmp((outside) =>
|
|
Effect.gen(function* () {
|
|
const targetPath = path.join(outside, "new.txt")
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: targetPath })
|
|
const root = outside
|
|
expect(target).toMatchObject({
|
|
absolute: path.join(root, "new.txt"),
|
|
resource: path.join(root, "new.txt").replaceAll("\\", "/"),
|
|
})
|
|
expect(target.externalDirectory).toMatchObject({
|
|
directory: root,
|
|
resource: path.join(root, "*").replaceAll("\\", "/"),
|
|
})
|
|
}).pipe(provide(directory)),
|
|
),
|
|
),
|
|
)
|
|
|
|
it.live("resolves an existing external file target", () =>
|
|
withTmp((directory) =>
|
|
withTmp((outside) =>
|
|
Effect.gen(function* () {
|
|
const targetPath = path.join(outside, "existing.txt")
|
|
yield* Effect.promise(() => fs.writeFile(targetPath, "existing"))
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: targetPath })
|
|
expect(target).toMatchObject({ absolute: targetPath })
|
|
expect(target.externalDirectory?.directory).toBe(outside)
|
|
}).pipe(provide(directory)),
|
|
),
|
|
),
|
|
)
|
|
|
|
it.live("uses an explicit file kind without treating an existing directory as the target boundary", () =>
|
|
withTmp((directory) =>
|
|
withTmp((outside) =>
|
|
Effect.gen(function* () {
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: outside, kind: "file" })
|
|
expect(target.externalDirectory).toMatchObject({
|
|
directory: path.dirname(outside),
|
|
resource: path.join(path.dirname(outside), "*").replaceAll("\\", "/"),
|
|
})
|
|
}).pipe(provide(directory)),
|
|
),
|
|
),
|
|
)
|
|
|
|
it.live("authorizes prospective external descendants at their lexical parent", () =>
|
|
withTmp((directory) =>
|
|
withTmp((outside) =>
|
|
Effect.gen(function* () {
|
|
const targetPath = path.join(outside, "new", "nested", "file.txt")
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: targetPath })
|
|
const parent = path.dirname(targetPath)
|
|
expect(target.externalDirectory).toMatchObject({
|
|
directory: parent,
|
|
resource: path.join(parent, "*").replaceAll("\\", "/"),
|
|
})
|
|
}).pipe(provide(directory)),
|
|
),
|
|
),
|
|
)
|
|
|
|
test("ignores unknown mutation input fields", () => {
|
|
expect(Object.keys(LocationMutation.ResolveInput.fields)).toEqual(["path", "kind"])
|
|
expect(Schema.decodeUnknownSync(LocationMutation.ResolveInput)({ path: "README.md", reference: "docs" })).toEqual({
|
|
path: "README.md",
|
|
})
|
|
})
|
|
|
|
test("expands a leading tilde against the home directory", () => {
|
|
const home = path.resolve("/Users/aiden")
|
|
expect(LocationMutation.resolvePath("/project", "~", home)).toBe(home)
|
|
expect(LocationMutation.resolvePath("/project", "~/notes.md", home)).toBe(path.resolve(home, "notes.md"))
|
|
expect(LocationMutation.resolvePath("/project", "~draft.md", home)).toBe(path.resolve("/project", "~draft.md"))
|
|
expect(LocationMutation.resolvePath("/project", "~\\notes.md", home)).toBe(
|
|
process.platform === "win32" ? path.resolve(home, "notes.md") : path.resolve("/project", "~\\notes.md"),
|
|
)
|
|
})
|
|
|
|
test.each([
|
|
["/c/Users/aiden/notes.md", "C:/Users/aiden/notes.md"],
|
|
["/C:/Users/aiden/notes.md", "C:/Users/aiden/notes.md"],
|
|
["/cygdrive/c/Users/aiden/notes.md", "C:/Users/aiden/notes.md"],
|
|
["/mnt/c/Users/aiden/notes.md", "C:/Users/aiden/notes.md"],
|
|
])("normalizes Windows shell drive path %s before resolution", (input, windows) => {
|
|
expect(LocationMutation.resolvePath("/project", input)).toBe(
|
|
process.platform === "win32" ? path.resolve(windows) : path.resolve(input),
|
|
)
|
|
})
|
|
|
|
it.live("resolves a tilde path as an external home target", () =>
|
|
withTmp((directory) =>
|
|
Effect.gen(function* () {
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: "~/notes.md" })
|
|
const absolute = path.resolve(Global.Path.home, "notes.md")
|
|
expect(target).toMatchObject({
|
|
absolute,
|
|
resource: absolute.replaceAll("\\", "/"),
|
|
})
|
|
expect(target.externalDirectory).toMatchObject({
|
|
directory: Global.Path.home,
|
|
resource: path.join(Global.Path.home, "*").replaceAll("\\", "/"),
|
|
})
|
|
}).pipe(provide(directory)),
|
|
),
|
|
)
|
|
|
|
it.live("treats a tilde path as in-location when the location is home", () =>
|
|
Effect.gen(function* () {
|
|
const mutation = yield* LocationMutation.Service
|
|
const target = yield* mutation.resolve({ path: "~/notes.md" })
|
|
expect(target).toMatchObject({
|
|
absolute: path.resolve(Global.Path.home, "notes.md"),
|
|
resource: "notes.md",
|
|
})
|
|
expect(target.externalDirectory).toBeUndefined()
|
|
}).pipe(provide(Global.Path.home)),
|
|
)
|
|
})
|