Catriel Müller
d7b9f51962
Update upstream merge scripts to use a generic x-opencode- → x-kilo- regex that catches all current and future headers automatically. Apply the same replacement to all source files so the codebase is ready for the next upstream merge.
120 lines
3.7 KiB
TypeScript
120 lines
3.7 KiB
TypeScript
import { afterEach, describe, expect, spyOn, test } from "bun:test"
|
|
import path from "path"
|
|
import { GlobalBus } from "../../src/bus/global"
|
|
import { Snapshot } from "../../src/snapshot"
|
|
import { InstanceBootstrap } from "../../src/project/bootstrap"
|
|
import { Instance } from "../../src/project/instance"
|
|
import { Server } from "../../src/server/server"
|
|
import { Filesystem } from "../../src/util/filesystem"
|
|
import { Log } from "../../src/util/log"
|
|
import { resetDatabase } from "../fixture/db"
|
|
import { tmpdir } from "../fixture/fixture"
|
|
|
|
Log.init({ print: false })
|
|
|
|
afterEach(async () => {
|
|
await resetDatabase()
|
|
})
|
|
|
|
describe("project.initGit endpoint", () => {
|
|
test("initializes git and reloads immediately", async () => {
|
|
await using tmp = await tmpdir()
|
|
const app = Server.App()
|
|
const seen: { directory?: string; payload: { type: string } }[] = []
|
|
const fn = (evt: { directory?: string; payload: { type: string } }) => {
|
|
seen.push(evt)
|
|
}
|
|
const reload = Instance.reload
|
|
const reloadSpy = spyOn(Instance, "reload").mockImplementation((input) => reload(input))
|
|
GlobalBus.on("event", fn)
|
|
|
|
try {
|
|
const init = await app.request("/project/git/init", {
|
|
method: "POST",
|
|
headers: {
|
|
"x-kilo-directory": tmp.path,
|
|
},
|
|
})
|
|
const body = await init.json()
|
|
expect(init.status).toBe(200)
|
|
expect(body).toMatchObject({
|
|
id: "global",
|
|
vcs: "git",
|
|
worktree: tmp.path,
|
|
})
|
|
expect(reloadSpy).toHaveBeenCalledTimes(1)
|
|
expect(reloadSpy.mock.calls[0]?.[0]?.init).toBe(InstanceBootstrap)
|
|
expect(seen.some((evt) => evt.directory === tmp.path && evt.payload.type === "server.instance.disposed")).toBe(
|
|
true,
|
|
)
|
|
expect(await Filesystem.exists(path.join(tmp.path, ".git", "opencode"))).toBe(false)
|
|
|
|
const current = await app.request("/project/current", {
|
|
headers: {
|
|
"x-kilo-directory": tmp.path,
|
|
},
|
|
})
|
|
expect(current.status).toBe(200)
|
|
expect(await current.json()).toMatchObject({
|
|
id: "global",
|
|
vcs: "git",
|
|
worktree: tmp.path,
|
|
})
|
|
|
|
await Instance.provide({
|
|
directory: tmp.path,
|
|
fn: async () => {
|
|
expect(await Snapshot.track()).toBeTruthy()
|
|
},
|
|
})
|
|
} finally {
|
|
reloadSpy.mockRestore()
|
|
GlobalBus.off("event", fn)
|
|
}
|
|
})
|
|
|
|
test("does not reload when the project is already git", async () => {
|
|
await using tmp = await tmpdir({ git: true })
|
|
const app = Server.App()
|
|
const seen: { directory?: string; payload: { type: string } }[] = []
|
|
const fn = (evt: { directory?: string; payload: { type: string } }) => {
|
|
seen.push(evt)
|
|
}
|
|
const reload = Instance.reload
|
|
const reloadSpy = spyOn(Instance, "reload").mockImplementation((input) => reload(input))
|
|
GlobalBus.on("event", fn)
|
|
|
|
try {
|
|
const init = await app.request("/project/git/init", {
|
|
method: "POST",
|
|
headers: {
|
|
"x-kilo-directory": tmp.path,
|
|
},
|
|
})
|
|
expect(init.status).toBe(200)
|
|
expect(await init.json()).toMatchObject({
|
|
vcs: "git",
|
|
worktree: tmp.path,
|
|
})
|
|
expect(
|
|
seen.filter((evt) => evt.directory === tmp.path && evt.payload.type === "server.instance.disposed").length,
|
|
).toBe(0)
|
|
expect(reloadSpy).toHaveBeenCalledTimes(0)
|
|
|
|
const current = await app.request("/project/current", {
|
|
headers: {
|
|
"x-kilo-directory": tmp.path,
|
|
},
|
|
})
|
|
expect(current.status).toBe(200)
|
|
expect(await current.json()).toMatchObject({
|
|
vcs: "git",
|
|
worktree: tmp.path,
|
|
})
|
|
} finally {
|
|
reloadSpy.mockRestore()
|
|
GlobalBus.off("event", fn)
|
|
}
|
|
})
|
|
})
|