FilesExpand file tree

main

/

check-coordinator-run.test.mjs

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

68 lines (60 loc) · 3.15 KB

main

/

check-coordinator-run.test.mjs

Copy path

Top

File metadata and controls

• Code
• Blame

68 lines (60 loc) · 3.15 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

import { describe, expect, it } from 'vitest';

import { analyzeCoordinatorRunLog, formatCoordinatorRunReport } from './check-coordinator-run.mjs';

describe('check-coordinator-run', () => {

it('passes when every spawned coordinated task logs backend initial-prompt delivery', () => {

const result = analyzeCoordinatorRunLog(`

[1] [01:00:00.000] [MCP info] create_task name=task-one baseBranch=task/root

[1] [01:00:00.100] DEBUG pty — spawn command agent-one {"taskId":"task-1","command":"codex"}

[1] [01:00:00.110] [MCP info] create_task OK id=task-1

[1] [01:00:00.500] INFO coordinator.initial_prompt — scheduled {"taskId":"task-1","agentId":"agent-one","delayMs":1500}

[1] [01:00:02.000] INFO coordinator.initial_prompt — delivered {"taskId":"task-1","agentId":"agent-one"}

[1] [01:00:03.000] [MCP info] create_task name=task-two baseBranch=task/root

[1] [01:00:03.100] DEBUG pty — spawn command agent-two {"taskId":"task-2","command":"codex"}

[1] [01:00:03.110] [MCP info] create_task OK id=task-2

[1] [01:00:03.500] INFO coordinator.initial_prompt — scheduled {"taskId":"task-2","agentId":"agent-two","delayMs":1500}

[1] [01:00:04.500] INFO coordinator.initial_prompt — delivered {"taskId":"task-2","agentId":"agent-two"}

`);

expect(result.tasks).toHaveLength(2);

expect(result.issues).toEqual([]);

});

it('flags startup control handoff with no backend initial-prompt delivery', () => {

const result = analyzeCoordinatorRunLog(`

[1] [01:13:57.267] [MCP info] create_task name=task-200-update-check-policy baseBranch=task/root

[1] [01:13:57.426] DEBUG pty — spawn command agent-one {"taskId":"task-200","command":"codex"}

[1] [01:13:57.427] [MCP info] create_task OK id=task-200

[1] [01:13:57.523] DEBUG ipc — mcp_control_changed

[1] [01:13:57.534] DEBUG ipc — write_to_agent

`);

expect(result.issues).toEqual([

expect.objectContaining({

severity: 'error',

code: 'initial_prompt_not_confirmed',

taskId: 'task-200',

taskName: 'task-200-update-check-policy',

detail: expect.stringContaining('startup control changed 97ms after spawn'),

}),

]);

});

it('distinguishes scheduled-but-not-delivered startup failures', () => {

const result = analyzeCoordinatorRunLog(`

[1] [01:13:57.267] [MCP info] create_task name=task-200-update-check-policy baseBranch=task/root

[1] [01:13:57.426] DEBUG pty — spawn command agent-one {"taskId":"task-200","command":"codex"}

[1] [01:13:57.427] [MCP info] create_task OK id=task-200

[1] [01:13:58.000] INFO coordinator.initial_prompt — scheduled {"taskId":"task-200","agentId":"agent-one","delayMs":1500}

`);

expect(result.issues).toEqual([

expect.objectContaining({

severity: 'error',

code: 'initial_prompt_not_confirmed',

taskId: 'task-200',

detail: expect.stringContaining('scheduled at line 5'),

}),

]);

});

it('reports when no coordinated task spawns are present', () => {

const result = analyzeCoordinatorRunLog('[1] [01:00:00.000] DEBUG ipc — get_mcp_status');

expect(formatCoordinatorRunReport(result, { file: '/tmp/run.out' })).toBe(

'run.out: no coordinated task spawns found',

);

});

});