Skip to content

test(opencode): isolate automation registry cross-platform #675

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
pascalandr wants to merge 1 commit into from
Closed

test(opencode): isolate automation registry cross-platform #675

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
48 changes: 31 additions & 17 deletions packages/server/src/opencode/automation-plugin.test.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ import path from "node:path"
import test from "node:test"
import {
AUTOMATION_BRIDGE_PATH,
automationBridgeDirectory,
automationBridgeDirectories,
createAutomationBridgeRegistration,
parseDeveloperAction,
Expand Down Expand Up @@ -50,6 +51,27 @@ function closeServer(server: http.Server | undefined): Promise<void> {
return new Promise((resolve) => server?.close(() => resolve()) ?? resolve())
}

function isolateAutomationRegistry(root: string): { directory: string; restore: () => void } {
const previousLocalAppData = process.env.LOCALAPPDATA
const previousXdgRuntimeDir = process.env.XDG_RUNTIME_DIR
const previousWslDistroName = process.env.WSL_DISTRO_NAME
process.env.LOCALAPPDATA = root
process.env.XDG_RUNTIME_DIR = root
delete process.env.WSL_DISTRO_NAME

return {
directory: automationBridgeDirectory(),
restore: () => {
if (previousLocalAppData === undefined) delete process.env.LOCALAPPDATA
else process.env.LOCALAPPDATA = previousLocalAppData
if (previousXdgRuntimeDir === undefined) delete process.env.XDG_RUNTIME_DIR
else process.env.XDG_RUNTIME_DIR = previousXdgRuntimeDir
if (previousWslDistroName === undefined) delete process.env.WSL_DISTRO_NAME
else process.env.WSL_DISTRO_NAME = previousWslDistroName
},
}
}

test("validates Developer Mode actions", () => {
assert.deepEqual(parseDeveloperAction({ action: "type", ref: "e4", text: "CodeNomad" }), {
action: "type",
Expand Down Expand Up @@ -100,8 +122,7 @@ test("removes only the generated legacy global plugin shim", async () => {

test("restart waits for a new native generation and returns a fresh inspection", async () => {
const root = await mkdtemp(path.join(os.tmpdir(), "codenomad-automation-restart-"))
const previousLocalAppData = process.env.LOCALAPPDATA
process.env.LOCALAPPDATA = root
const registry = isolateAutomationRegistry(root)
const definitions: ToolDefinition[] = []
let removeOld: (() => Promise<void>) | undefined
let removeNew: (() => Promise<void>) | undefined
Expand Down Expand Up @@ -162,16 +183,14 @@ test("restart waits for a new native generation and returns a fresh inspection",
await closeServer(newServer)
await closeServer(preexistingServer)
await Promise.all(distractorServers.map(closeServer))
if (previousLocalAppData === undefined) delete process.env.LOCALAPPDATA
else process.env.LOCALAPPDATA = previousLocalAppData
registry.restore()
await rm(root, { recursive: true, force: true })
}
})

test("keeps inspected targets isolated per plugin setup", async () => {
const root = await mkdtemp(path.join(os.tmpdir(), "codenomad-automation-isolation-"))
const previousLocalAppData = process.env.LOCALAPPDATA
process.env.LOCALAPPDATA = root
const registry = isolateAutomationRegistry(root)
let removeBridge: (() => Promise<void>) | undefined
let server: http.Server | undefined
try {
Expand All @@ -190,16 +209,14 @@ test("keeps inspected targets isolated per plugin setup", async () => {
} finally {
await removeBridge?.()
await closeServer(server)
if (previousLocalAppData === undefined) delete process.env.LOCALAPPDATA
else process.env.LOCALAPPDATA = previousLocalAppData
registry.restore()
await rm(root, { recursive: true, force: true })
}
})

test("pins parallel sessions to their independently inspected bridges", async () => {
const root = await mkdtemp(path.join(os.tmpdir(), "codenomad-automation-sessions-"))
const previousLocalAppData = process.env.LOCALAPPDATA
process.env.LOCALAPPDATA = root
const registry = isolateAutomationRegistry(root)
const removals: Array<() => Promise<void>> = []
const servers: http.Server[] = []
try {
Expand All @@ -220,16 +237,14 @@ test("pins parallel sessions to their independently inspected bridges", async ()
} finally {
await Promise.all(removals.map((remove) => remove()))
await Promise.all(servers.map(closeServer))
if (previousLocalAppData === undefined) delete process.env.LOCALAPPDATA
else process.env.LOCALAPPDATA = previousLocalAppData
registry.restore()
await rm(root, { recursive: true, force: true })
}
})

test("prunes stale registry pressure before limiting discovery", async () => {
const root = await mkdtemp(path.join(os.tmpdir(), "codenomad-automation-stale-"))
const previousLocalAppData = process.env.LOCALAPPDATA
process.env.LOCALAPPDATA = root
const registry = isolateAutomationRegistry(root)
let removeBridge: (() => Promise<void>) | undefined
let server: http.Server | undefined
try {
Expand All @@ -238,7 +253,7 @@ test("prunes stale registry pressure before limiting discovery", async () => {
: { result: { target: { id: "live", title: "Live", url: "http://app.test" }, nodes: [], diagnostics: [] } })
server = bridge.server
removeBridge = await publishAutomationBridge(createAutomationBridgeRegistration(bridge.url))
const directory = path.join(root, "CodeNomad", "automation-bridges")
const directory = registry.directory
const base = Date.now() + 10_000
for (let index = 0; index < 70; index += 1) {
const startedAt = base + index
Expand All @@ -257,8 +272,7 @@ test("prunes stale registry pressure before limiting discovery", async () => {
} finally {
await removeBridge?.()
await closeServer(server)
if (previousLocalAppData === undefined) delete process.env.LOCALAPPDATA
else process.env.LOCALAPPDATA = previousLocalAppData
registry.restore()
await rm(root, { recursive: true, force: true })
}
})
Loading