mosaicstack/stack
1
0
Fork 0
Code Issues 58 Pull Requests 1 Actions Packages Projects Releases 15 Wiki Activity

test(fleet): make CRUD projection recovery deterministic
All checks were successful
ci/woodpecker/pr/ci Pipeline was successful
Details

Browse Source 
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
This commit is contained in:
Jarvis
2026-07-15 06:54:02 -05:00
parent 23d58cdb90
commit 128cc81c39
1 changed files with 20 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
packages/mosaic/src/commands/fleet-agent-crud-command.spec.ts
View File

@@ -4,7 +4,6 @@ import { join } from 'node:path';
import { Command } from 'commander'; import { Command } from 'commander';
import { afterEach, describe, expect, it, vi } from 'vitest'; import { afterEach, describe, expect, it, vi } from 'vitest';
import { fleetAgentMutationExitCode } from './fleet-agent-crud-command.js'; import { fleetAgentMutationExitCode } from './fleet-agent-crud-command.js';
import { applyPreparedAgentEnvironmentProjection } from '../fleet/generated-env-boundary.js';
import { registerFleetCommand, type FleetCommandDeps } from './fleet.js'; import { registerFleetCommand, type FleetCommandDeps } from './fleet.js';
const roster = ` const roster = `
@@ -389,25 +388,20 @@ describe('mosaic fleet local roster mutations', (): void => {
const agentsDir = join(home, 'fleet', 'agents'); const agentsDir = join(home, 'fleet', 'agents');
const captured = output(); const captured = output();
try { await program(home, {
await program(home, { projectionApplier: async (): Promise<never> => {
projectionApplier: async (prepared): Promise<unknown> => { throw new Error('injected projection failure');
await chmod(agentsDir, 0o500); },
return applyPreparedAgentEnvironmentProjection(prepared); }).parseAsync([
}, 'node',
}).parseAsync([ 'mosaic',
'node', 'fleet',
'mosaic', 'create',
'fleet', '--expected-generation',
'create', '7',
'--expected-generation', '--agent',
'7', JSON.stringify(agent),
'--agent', ]);
JSON.stringify(agent),
]);
} finally {
await chmod(agentsDir, 0o700);
}
expect(JSON.parse(captured.lines.join('\n'))).toMatchObject({ expect(JSON.parse(captured.lines.join('\n'))).toMatchObject({
applied: false, applied: false,
@@ -525,17 +519,12 @@ describe('mosaic fleet local roster mutations', (): void => {
JSON.stringify(agent), JSON.stringify(agent),
]); ]);
try { captured.lines.length = 0;
captured.lines.length = 0; await program(home, {
await program(home, { projectionApplier: async (): Promise<never> => {
projectionApplier: async (prepared): Promise<unknown> => { throw new Error('injected projection failure');
await chmod(agentsDir, 0o500); },
return applyPreparedAgentEnvironmentProjection(prepared); }).parseAsync(['node', 'mosaic', 'fleet', 'delete', 'coder0', '--expected-generation', '8']);
},
}).parseAsync(['node', 'mosaic', 'fleet', 'delete', 'coder0', '--expected-generation', '8']);
} finally {
await chmod(agentsDir, 0o700);
}
expect(JSON.parse(captured.lines.pop() ?? '')).toMatchObject({ expect(JSON.parse(captured.lines.pop() ?? '')).toMatchObject({
applied: false, applied: false,