Compare commits
4 Commits
release/mo
...
feat/f3-m2
| Author | SHA1 | Date | |
|---|---|---|---|
| 5c643cd54e | |||
| b26bbb02e9 | |||
| bda38bddc1 | |||
| 56e5c35678 |
@@ -32,15 +32,8 @@ MOSAIC_AGENT_COMMAND='bash --noprofile --norc -i' \
|
|||||||
"$START" "$AGENT"
|
"$START" "$AGENT"
|
||||||
|
|
||||||
tmux -L "$SOCKET" has-session -t "=$AGENT:0.0" || fail "agent session was not created"
|
tmux -L "$SOCKET" has-session -t "=$AGENT:0.0" || fail "agent session was not created"
|
||||||
# Retry: pane_current_path briefly reflects the tmux server's cwd until the pane
|
actual_dir=$(tmux -L "$SOCKET" display-message -p -t "=$AGENT:0.0" '#{pane_current_path}')
|
||||||
# process establishes its own cwd (the -c start dir). Poll until it settles.
|
[ "$actual_dir" = "$WORKDIR" ] || fail "agent workdir mismatch: $actual_dir"
|
||||||
actual_dir=""
|
|
||||||
for _ in $(seq 1 30); do
|
|
||||||
actual_dir=$(tmux -L "$SOCKET" display-message -p -t "=$AGENT:0.0" '#{pane_current_path}')
|
|
||||||
[ "$actual_dir" = "$WORKDIR" ] && break
|
|
||||||
sleep 0.1
|
|
||||||
done
|
|
||||||
[ "$actual_dir" = "$WORKDIR" ] || fail "agent workdir mismatch: $actual_dir (expected $WORKDIR)"
|
|
||||||
|
|
||||||
# ── Test 2: idempotency (duplicate start prints 'already running') ─────────────
|
# ── Test 2: idempotency (duplicate start prints 'already running') ─────────────
|
||||||
MOSAIC_TMUX_SOCKET="$SOCKET" \
|
MOSAIC_TMUX_SOCKET="$SOCKET" \
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@mosaicstack/mosaic",
|
"name": "@mosaicstack/mosaic",
|
||||||
"version": "0.0.38",
|
"version": "0.0.37",
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
"url": "https://git.mosaicstack.dev/mosaicstack/stack.git",
|
"url": "https://git.mosaicstack.dev/mosaicstack/stack.git",
|
||||||
|
|||||||
@@ -1453,19 +1453,15 @@ export function registerFleetAgentCommands(
|
|||||||
|
|
||||||
await runChecked(runner, buildAgentWatchCreateViewerCommand(agent, viewerName, socketName));
|
await runChecked(runner, buildAgentWatchCreateViewerCommand(agent, viewerName, socketName));
|
||||||
|
|
||||||
let exitCode = 0;
|
const [bin, args] = splitCommand(buildAgentWatchAttachCommand(viewerName, socketName));
|
||||||
try {
|
const exitCode = await iRunner(bin, args);
|
||||||
const [bin, args] = splitCommand(buildAgentWatchAttachCommand(viewerName, socketName));
|
|
||||||
exitCode = await iRunner(bin, args);
|
// Best-effort cleanup of the viewer session regardless of how the user detached.
|
||||||
} finally {
|
// Errors here are intentionally suppressed — the agent session is unaffected.
|
||||||
// ALWAYS clean up the viewer session — even if attach threw or the process was
|
const killResult = await runner(
|
||||||
// interrupted — so stale grouped *-watch-* sessions never accumulate. Errors here
|
...splitCommand(buildAgentWatchKillViewerCommand(viewerName, socketName)),
|
||||||
// are intentionally suppressed; the agent session is unaffected.
|
);
|
||||||
const killResult = await runner(
|
void killResult; // result is intentionally ignored
|
||||||
...splitCommand(buildAgentWatchKillViewerCommand(viewerName, socketName)),
|
|
||||||
);
|
|
||||||
void killResult;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (exitCode !== 0) {
|
if (exitCode !== 0) {
|
||||||
process.exitCode = exitCode;
|
process.exitCode = exitCode;
|
||||||
|
|||||||
Reference in New Issue
Block a user