mirror of
https://github.com/getpaseo/paseo.git
synced 2026-10-24 10:12:44 +00:00
Mohamed Boudra
c8a417c4fb
* feat(terminals): expose workspace ownership through the SDK and CLI Directory-based terminal creation selected the oldest workspace sharing that path. Expose explicit workspace ownership in the shared public API and CLI, retain ownership and process directories in listings, and acknowledge terminal deletion after teardown. * fix(file-observer): preserve nested shallow reconciliation scopes A parent directory scan does not visit its descendants. Collapsing change scopes discarded nested scans and left coalesced native deletions unseen until a full audit. * test(terminals): extract output waits from end-to-end scenarios
81 lines
3.1 KiB
TypeScript
81 lines
3.1 KiB
TypeScript
import assert from "node:assert/strict";
|
|
import { createPaseoClient } from "@getpaseo/client";
|
|
import { createE2ETestContext } from "./helpers/test-daemon.ts";
|
|
import { waitForTerminalOutput } from "./helpers/terminal.ts";
|
|
|
|
const ctx = await createE2ETestContext({ timeout: 30_000 });
|
|
const sdk = createPaseoClient({ url: `${ctx.wsUrl}/ws`, reconnect: { enabled: false } });
|
|
|
|
async function cli(args: string[]) {
|
|
const result = await ctx.paseo([...args, "--json"]);
|
|
assert.equal(result.exitCode, 0, result.stderr);
|
|
return JSON.parse(result.stdout);
|
|
}
|
|
|
|
try {
|
|
await sdk.connect();
|
|
const first = await sdk.workspaces.create({
|
|
source: { kind: "directory", path: ctx.workDir },
|
|
title: "main",
|
|
});
|
|
const second = await sdk.workspaces.create({
|
|
source: { kind: "directory", path: ctx.workDir },
|
|
title: "feature-work",
|
|
});
|
|
const main = await cli(["terminal", "create", "--cwd", ctx.workDir, "--name", "Main"]);
|
|
assert.equal(main.workspaceId, first.id);
|
|
const feature = await cli(["terminal", "create", "--workspace", second.id, "--name", "Feature"]);
|
|
assert.deepEqual(feature, {
|
|
id: feature.id,
|
|
name: "Feature",
|
|
cwd: ctx.workDir,
|
|
workspaceId: second.id,
|
|
});
|
|
assert.deepEqual(await cli(["terminal", "ls", "--workspace", second.id]), [feature]);
|
|
assert.deepEqual(await cli(["terminal", "ls", "--cwd", ctx.workDir]), [main, feature]);
|
|
assert.deepEqual(await cli(["terminal", "ls", "--all"]), [main, feature]);
|
|
const invalid = await ctx.paseo([
|
|
"terminal",
|
|
"create",
|
|
"--workspace",
|
|
"wks_missing",
|
|
"--cwd",
|
|
ctx.workDir,
|
|
"--json",
|
|
]);
|
|
assert.notEqual(invalid.exitCode, 0);
|
|
assert.match(invalid.stderr, /not active or does not exist/);
|
|
const conflict = await ctx.paseo(["terminal", "ls", "--all", "--workspace", second.id]);
|
|
assert.notEqual(conflict.exitCode, 0);
|
|
|
|
const terminal = await second.terminals.create({
|
|
command: process.execPath,
|
|
args: [
|
|
"-e",
|
|
"process.stdin.setRawMode(true); process.stdin.resume(); console.log('READY'); let hex = ''; process.stdin.on('data', data => { hex += data.toString('hex'); console.log('HEX:' + hex); });",
|
|
],
|
|
});
|
|
await waitForTerminalOutput(ctx.paseo, terminal.id, "READY");
|
|
assert.deepEqual(await cli(["terminal", "send-keys", terminal.id, "-l", "Enter"]), {
|
|
terminalId: terminal.id,
|
|
keysSent: 5,
|
|
});
|
|
await waitForTerminalOutput(ctx.paseo, terminal.id, "HEX:456e746572");
|
|
assert.deepEqual(await cli(["terminal", "send-keys", terminal.id, "Enter"]), {
|
|
terminalId: terminal.id,
|
|
keysSent: 1,
|
|
});
|
|
await waitForTerminalOutput(ctx.paseo, terminal.id, "HEX:456e7465720d");
|
|
assert.deepEqual(await cli(["terminal", "kill", terminal.id]), {
|
|
terminalId: terminal.id,
|
|
success: true,
|
|
});
|
|
await cli(["terminal", "kill", feature.id]);
|
|
assert.deepEqual(await cli(["terminal", "ls", "--workspace", second.id]), []);
|
|
assert.deepEqual(await cli(["terminal", "ls", "--workspace", first.id]), [main]);
|
|
console.log("Terminal workspace CLI: ownership, lists, input, capture, kill, and errors passed");
|
|
} finally {
|
|
await sdk.close();
|
|
await ctx.stop();
|
|
}
|