Something went wrong. Try again.
opencode v2 mirror
Something went wrong. Try again.
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585import { describe, expect } from "bun:test"import { $ } from "bun"import fs from "fs/promises"import path from "path"import { Effect, Stream } from "effect"import { AppNodeBuilder } from "@opencode/core/effect/app-node-builder"import { LayerNode } from "@opencode/util/effect/layer-node"import { Bus } from "@opencode/core/bus"import { Database } from "@opencode/core/database/database"import { Project } from "@opencode/core/project"import { ProjectSchema } from "@opencode/core/project/schema"import { ProjectTable } from "@opencode/core/project/sql"import { AbsolutePath } from "@opencode/core/schema"import { Hash } from "@opencode/util/hash"import { tmpdir } from "./fixture/tmpdir"import { testEffect } from "./lib/effect"
const it = testEffect(AppNodeBuilder.build(LayerNode.group([Project.node, Database.node, Bus.node])))
describe("Project.list", () => { it.effect("returns complete projects ordered by recent activity", () => Effect.gen(function* () { const db = (yield* Database.Service).db const project = yield* Project.Service yield* db .insert(ProjectTable) .values([ { id: Project.ID.make("older"), worktree: abs("/older"), vcs: "git", name: "Older", icon_color: "#000000", commands: { start: "bun dev" }, sandboxes: [abs("/older/sandbox")], time_created: 1, time_updated: 1, time_active: 4, }, { id: Project.ID.make("newer"), worktree: abs("/newer"), sandboxes: [], time_created: 2, time_updated: 2, time_initialized: 3, time_active: 3, }, ]) .run()
expect(yield* project.list()).toEqual([ { id: Project.ID.make("older"), canonical: abs("/older"), vcs: "git", name: "Older", icon: { color: "#000000" }, commands: { start: "bun dev" }, time: { created: 1, updated: 1, active: 4 }, sandboxes: [abs("/older/sandbox")], }, { id: Project.ID.make("newer"), canonical: abs("/newer"), time: { created: 2, updated: 2, active: 3 }, sandboxes: [], }, ]) }), )})
describe("Project.update", () => { it.effect("updates and clears project metadata", () => Effect.gen(function* () { const db = (yield* Database.Service).db const project = yield* Project.Service const id = Project.ID.make("update") yield* db .insert(ProjectTable) .values({ id, worktree: abs("/update"), sandboxes: [], time_created: 1, time_updated: 1, time_active: 1, }) .run()
expect( yield* project.update({ projectID: id, name: "Updated", icon: { color: "blue", override: "data:image/png;base64,test" }, commands: { start: "bun install" }, }), ).toMatchObject({ id, name: "Updated", icon: { color: "blue", override: "data:image/png;base64,test" }, commands: { start: "bun install" }, })
expect( yield* project.update({ projectID: id, name: "", icon: { color: "", override: "" }, commands: { start: "" }, }), ).toMatchObject({ id }) expect((yield* project.list())[0]).toEqual({ id, canonical: abs("/update"), time: { created: 1, updated: expect.any(Number), active: 1 }, sandboxes: [], }) }), )})
describe("Project.activate", () => { it.effect("records activity without editing metadata time and throttles repeats", () => Effect.gen(function* () { const db = (yield* Database.Service).db const project = yield* Project.Service const id = Project.ID.make("activate") yield* db .insert(ProjectTable) .values({ id, worktree: abs("/activate"), sandboxes: [], time_created: 1, time_updated: 1, time_active: 1 }) .run()
yield* project.activate(id) const first = (yield* project.list())[0] expect(first?.time.updated).toBe(1) expect(first?.time.active).toBeGreaterThan(1)
yield* db.update(ProjectTable).set({ time_active: 2, time_updated: 1 }).run() yield* project.activate(id) expect((yield* project.list())[0]?.time).toEqual({ created: 1, updated: 1, active: 2 }) }), )})
function remoteID(remote: string) { return Project.ID.make(Hash.fast(`git-remote:${remote}`))}
function abs(value: string) { return AbsolutePath.make(value)}
function real(value: string) { return Effect.promise(() => fs.realpath(value)).pipe(Effect.map((value) => AbsolutePath.make(value)))}
async function initRepo(dir: string, opts?: { commit?: boolean; remote?: string }) { await $`git init`.cwd(dir).quiet() await $`git config core.fsmonitor false`.cwd(dir).quiet() await $`git config commit.gpgsign false`.cwd(dir).quiet() await $`git config user.email test@opencode.test`.cwd(dir).quiet() await $`git config user.name Test`.cwd(dir).quiet() if (opts?.commit) await $`git commit --allow-empty -m root`.cwd(dir).quiet() if (opts?.remote) await $`git remote add origin ${opts.remote}`.cwd(dir).quiet()}
async function rootCommit(dir: string) { return (await $`git rev-list --max-parents=0 HEAD`.cwd(dir).text()).trim()}
describe("Project.resolve", () => { it.live("creates distinct deterministic projects for exact markerless directories", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) const project = yield* Project.Service const nested = path.join(tmp.path, "notes", "drafts") yield* Effect.promise(() => fs.mkdir(nested, { recursive: true }))
const result = yield* project.resolve(abs(tmp.path)) const repeated = yield* project.resolve(abs(`${tmp.path}${path.sep}.`)) const child = yield* project.resolve(abs(nested))
expect(result.id).not.toBe(Project.ID.global) expect(repeated.id).toBe(result.id) expect(child.id).not.toBe(result.id) expect(result.directory).toBe(yield* real(tmp.path)) expect(child.directory).toBe(yield* real(nested)) expect(result.canonical).toBe(result.directory) expect(result.previous).toBeUndefined() expect(result.vcs).toBeUndefined() }), )
it.live("repository markers override markerless directory projects", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) const nested = path.join(tmp.path, "packages", "app") yield* Effect.promise(() => fs.mkdir(nested, { recursive: true })) const project = yield* Project.Service const root = yield* project.resolve(abs(tmp.path)) const child = yield* project.resolve(abs(nested))
yield* Effect.promise(() => initRepo(tmp.path, { commit: true })) const repository = yield* project.resolve(abs(nested))
expect(root.id).not.toBe(child.id) expect(repository.id).not.toBe(root.id) expect(repository.id).not.toBe(child.id) expect(repository.directory).toBe(yield* real(tmp.path)) expect(repository.vcs?.type).toBe("git") }), )
it.live("does not publish project updates for first or repeated resolutions", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(tmp.path, { commit: true, remote: "git@github.com:owner/repo.git" })) const project = yield* Project.Service const bus = yield* Bus.Service const updates: Project.Info[] = [] yield* bus.subscribe(ProjectSchema.Event.Updated).pipe( Stream.runForEach((event) => Effect.sync(() => updates.push(event.data))), Effect.forkScoped({ startImmediately: true }), )
yield* project.resolve(abs(tmp.path)) yield* project.resolve(abs(tmp.path)) yield* Effect.yieldNow
expect(updates).toEqual([]) }), )
it.live("publishes preserved project metadata when its canonical directory is renamed", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) const before = path.join(tmp.path, "before") const after = path.join(tmp.path, "after") yield* Effect.promise(() => fs.mkdir(before)) yield* Effect.promise(() => initRepo(before, { commit: true, remote: "git@github.com:owner/repo.git" })) const project = yield* Project.Service const bus = yield* Bus.Service const initial = yield* project.resolve(abs(before)) yield* project.update({ projectID: initial.id, name: "Preserved name" }) const updates: Project.Info[] = [] yield* bus.subscribe(ProjectSchema.Event.Updated).pipe( Stream.runForEach((event) => Effect.sync(() => updates.push(event.data))), Effect.forkScoped({ startImmediately: true }), )
yield* Effect.promise(() => fs.rename(before, after)) const renamed = yield* project.resolve(abs(after)) yield* Effect.yieldNow
expect(renamed.id).toBe(initial.id) expect(renamed.canonical).toBe(yield* real(after)) expect(updates).toHaveLength(1) expect(updates).toEqual((yield* project.list()).filter((item) => item.id === initial.id)) expect(updates[0]).toMatchObject({ id: initial.id, canonical: yield* real(after), name: "Preserved name", }) }), )
it.live("keeps the canonical project directory when opening another clone", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) const main = path.join(tmp.path, "repo") const clone = path.join(tmp.path, "other-clone") const linked = path.join(tmp.path, "linked") yield* Effect.promise(async () => { await fs.mkdir(main) await initRepo(main, { commit: true, remote: "git@github.com:owner/repo.git" }) await $`git clone --no-hardlinks ${main} ${clone}`.quiet() await $`git remote set-url origin https://github.com/owner/repo.git`.cwd(clone).quiet() await $`git worktree add ${linked} -b linked`.cwd(main).quiet() }) const project = yield* Project.Service const bus = yield* Bus.Service const initial = yield* project.resolve(abs(main)) const updates: Project.Info[] = [] yield* bus.subscribe(ProjectSchema.Event.Updated).pipe( Stream.runForEach((event) => Effect.sync(() => updates.push(event.data))), Effect.forkScoped({ startImmediately: true }), )
for (const directory of [clone, linked, main, clone]) { const resolved = yield* project.resolve(abs(directory)) expect(resolved.id).toBe(initial.id) expect(resolved.directory).toBe(abs(directory)) expect(resolved.canonical).toBe(abs(directory === clone ? clone : main)) expect((yield* project.list()).find((item) => item.id === initial.id)?.canonical).toBe(abs(main)) } yield* Effect.yieldNow
expect(updates).toEqual([]) }), )
it.live("returns git global for repo with no commits and no remote", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(tmp.path)) const project = yield* Project.Service
const result = yield* project.resolve(abs(tmp.path))
expect(result.id).toBe(Project.ID.make("global")) expect(result.directory).toBe(yield* real(tmp.path)) expect(result.canonical).toBe(result.directory) expect(result.previous).toBeUndefined() expect(result.vcs?.type).toBe("git") }), )
it.live("falls back to root commit when origin is missing", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(tmp.path, { commit: true })) const project = yield* Project.Service
const result = yield* project.resolve(abs(tmp.path))
expect(result.id).toBe(Project.ID.make(yield* Effect.promise(() => rootCommit(tmp.path)))) expect(result.directory).toBe(yield* real(tmp.path)) expect(result.canonical).toBe(result.directory) expect(result.previous).toBeUndefined() expect(result.vcs?.type).toBe("git") }), )
it.live("prefers normalized origin over root commit", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(tmp.path, { commit: true, remote: "git@github.com:Acme/App.git" })) const project = yield* Project.Service
const result = yield* project.resolve(abs(tmp.path))
expect(result.id).toBe(remoteID("github.com/Acme/App")) expect(result.id).not.toBe(Project.ID.make(yield* Effect.promise(() => rootCommit(tmp.path)))) expect(result.directory).toBe(yield* real(tmp.path)) expect(result.vcs?.type).toBe("git") }), )
it.live("normalizes ssh and https remotes to the same id", () => Effect.gen(function* () { const ssh = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) const https = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(ssh.path, { commit: true, remote: "git@github.com:owner/repo.git" })) yield* Effect.promise(() => initRepo(https.path, { commit: true, remote: "https://github.com/owner/repo.git" })) const project = yield* Project.Service
const a = yield* project.resolve(abs(ssh.path)) const b = yield* project.resolve(abs(https.path))
expect(a.id).toBe(remoteID("github.com/owner/repo")) expect(b.id).toBe(a.id) }), )
it.live("ignores file remotes and falls back to root commit", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(tmp.path, { commit: true, remote: `file://${tmp.path}` })) const project = yield* Project.Service
const result = yield* project.resolve(abs(tmp.path))
expect(result.id).toBe(Project.ID.make(yield* Effect.promise(() => rootCommit(tmp.path)))) }), )
it.live("returns previous cached id from common dir", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(tmp.path, { commit: true, remote: "git@github.com:owner/repo.git" })) yield* Effect.promise(() => Bun.write(path.join(tmp.path, ".git", "opencode"), "old-id")) const project = yield* Project.Service
const result = yield* project.resolve(abs(tmp.path))
expect(result.previous).toBe(Project.ID.make("old-id")) expect(result.id).toBe(remoteID("github.com/owner/repo")) }), )
it.live("does not write the cache while resolving", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(tmp.path, { commit: true, remote: "git@github.com:owner/repo.git" })) const project = yield* Project.Service
yield* project.resolve(abs(tmp.path))
expect(yield* Effect.promise(() => Bun.file(path.join(tmp.path, ".git", "opencode")).exists())).toBe(false) }), )
it.live("resolves from nested directories to repo root", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(tmp.path, { commit: true })) yield* Effect.promise(() => fs.mkdir(path.join(tmp.path, "a", "b"), { recursive: true })) const project = yield* Project.Service
const result = yield* project.resolve(abs(path.join(tmp.path, "a", "b")))
expect(result.directory).toBe(yield* real(tmp.path)) }), )
it.live("prefers git when both git and mercurial metadata exist", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => initRepo(tmp.path, { commit: true })) yield* Effect.promise(() => fs.mkdir(path.join(tmp.path, ".hg"))) const project = yield* Project.Service
const result = yield* project.resolve(abs(tmp.path))
expect(result.vcs?.type).toBe("git") }), )
it.live("prefers the nearest mercurial marker over an outer git repository", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) const nested = path.join(tmp.path, "nested") yield* Effect.promise(async () => { await initRepo(tmp.path, { commit: true }) await fs.mkdir(path.join(nested, ".hg"), { recursive: true }) await fs.mkdir(path.join(nested, "app")) }) const project = yield* Project.Service
const result = yield* project.resolve(abs(path.join(nested, "app")))
expect(result.vcs?.type).toBe("hg") expect(result.directory).toBe(yield* real(nested)) }), )
it.live("prefers the nearest git marker over an outer mercurial repository", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) const nested = path.join(tmp.path, "nested") yield* Effect.promise(async () => { await fs.mkdir(path.join(tmp.path, ".hg")) await fs.mkdir(path.join(nested, "app"), { recursive: true }) await initRepo(nested, { commit: true }) }) const project = yield* Project.Service
const result = yield* project.resolve(abs(path.join(nested, "app")))
expect(result.vcs?.type).toBe("git") expect(result.directory).toBe(yield* real(nested)) }), )
it.live("returns global id for unreadable mercurial metadata", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) yield* Effect.promise(() => fs.mkdir(path.join(tmp.path, ".hg"))) const project = yield* Project.Service
const result = yield* project.resolve(abs(tmp.path))
expect(result.vcs?.type).toBe("hg") expect(result.id).toBe(Project.ID.make("global")) }), )
it.live("linked worktree returns opened worktree directory and previous from common dir", () => Effect.gen(function* () { const tmp = yield* Effect.acquireRelease( Effect.promise(() => tmpdir()), (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()), ) const worktree = `${tmp.path}-worktree` yield* Effect.addFinalizer(() => Effect.promise(() => $`rm -rf ${worktree}`.quiet().nothrow()).pipe(Effect.ignore), ) yield* Effect.promise(() => initRepo(tmp.path, { commit: true, remote: "git@github.com:owner/repo.git" })) yield* Effect.promise(() => Bun.write(path.join(tmp.path, ".git", "opencode"), "old-id")) yield* Effect.promise(() => $`git worktree add ${worktree} -b test-${Date.now()}`.cwd(tmp.path).quiet()) const project = yield* Project.Service const db = (yield* Database.Service).db const id = remoteID("github.com/owner/repo") yield* db .insert(ProjectTable) .values({ id, worktree: abs("/stale-worktree"), vcs: "hg", name: "Preserved name", icon_color: "#123456", commands: { start: "bun dev" }, sandboxes: [abs("/preserved-sandbox")], time_created: 1, time_updated: 1, time_initialized: 2, }) .run()
const result = yield* project.resolve(abs(worktree))
expect(result.directory).toBe(yield* real(worktree)) expect(result.canonical).toBe(yield* real(tmp.path)) expect(result.previous).toBe(Project.ID.make("old-id")) expect(result.id).toBe(id) expect(result.vcs?.type).toBe("git") expect((yield* project.list()).find((item) => item.id === id)).toMatchObject({ canonical: yield* real(tmp.path), vcs: "git", name: "Preserved name", icon: { color: "#123456" }, commands: { start: "bun dev" }, sandboxes: [abs("/preserved-sandbox")], time: { created: 1 }, }) }), )})