25285777631

Committed 03 May 2026 05:24PM UTC coverage: 64.503% (-0.09%) from 64.591%

Build # 25285777631

Build Type

Pull #601

github

Committed by

web-flow

Commit Message

Merge ef1e7f917 into f31be1c65

Pull Request Pull Request #601: feat: marmot protocol

Coverage Stats

1774 of 3101 branches covered (57.21%)

Branch coverage included in aggregate %.

35 of 64 new or added lines in 7 files covered. (54.69%)

2 existing lines in 2 files now uncovered.

4119 of 6035 relevant lines covered (68.25%)

18.51 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

3.8

/src/cli/utils/process.ts

import { spawn } from 'child_process'

export type RunOptions = {
  cwd?: string
  env?: NodeJS.ProcessEnv
  stdio?: 'inherit' | 'pipe'
  timeoutMs?: number
}

export type CommandResult =
  | { ok: true; code: number; stdout: string; stderr: string }
  | { ok: false; reason: 'not-found' | 'permission-denied' | 'spawn-error' | 'timeout' | 'signal'; stdout: string; stderr: string }

export const runCommand = (command: string, args: string[], options: RunOptions = {}): Promise<number> => {
  return new Promise((resolve, reject) => {
    const child = spawn(command, args, {
      cwd: options.cwd,
      env: { ...process.env, ...(options.env ?? {}) },
      stdio: options.stdio ?? 'inherit',
      shell: false,
    })

    const timer =
      typeof options.timeoutMs === 'number'
        ? setTimeout(() => {
            child.kill('SIGTERM')
          }, options.timeoutMs)
        : undefined

    child.on('error', reject)
    child.on('close', (code) => {
      if (timer) {
        clearTimeout(timer)
      }

      resolve(code ?? 1)
    })
  })
}

export const runCommandWithOutput = (
  command: string,
  args: string[],
  options: RunOptions = {},
): Promise<CommandResult> => {
  return new Promise((resolve) => {
    let stdout = ''
    let stderr = ''
    let timedOut = false
    let settled = false

    const settle = (result: CommandResult) => {
      if (!settled) {
        settled = true
        resolve(result)
      }
    }

    const child = spawn(command, args, {
      cwd: options.cwd,
      env: { ...process.env, ...(options.env ?? {}) },
      stdio: 'pipe',
      shell: false,
    })

    const timer =
      typeof options.timeoutMs === 'number'
        ? setTimeout(() => {
            timedOut = true
            child.kill('SIGTERM')
          }, options.timeoutMs)
        : undefined

    child.stdout.on('data', (chunk) => {
      stdout += chunk.toString()
    })

    child.stderr.on('data', (chunk) => {
      stderr += chunk.toString()
    })

    child.on('error', (err: NodeJS.ErrnoException) => {
      if (timer) { clearTimeout(timer) }
      if (err.code === 'ENOENT') {
        settle({ ok: false, reason: 'not-found', stdout, stderr })
      } else if (err.code === 'EACCES') {
        settle({ ok: false, reason: 'permission-denied', stdout, stderr })
      } else {
        settle({ ok: false, reason: 'spawn-error', stdout, stderr })
      }
    })

    child.on('close', (code, signal) => {
      if (timer) { clearTimeout(timer) }

      if (timedOut) {
        settle({ ok: false, reason: 'timeout', stdout, stderr })
        return
      }

      if (signal !== null && code === null) {
        settle({ ok: false, reason: 'signal', stdout, stderr })
        return
      }

      settle({ ok: true, code: code ?? 1, stdout, stderr })
    })
  })
}

1	import { spawn } from 'child_process'	2✔
2
3	export type RunOptions = {
4	cwd?: string
5	env?: NodeJS.ProcessEnv
6	stdio?: 'inherit' \| 'pipe'
7	timeoutMs?: number
8	}
9
10	export type CommandResult =
11	\| { ok: true; code: number; stdout: string; stderr: string }
12	\| { ok: false; reason: 'not-found' \| 'permission-denied' \| 'spawn-error' \| 'timeout' \| 'signal'; stdout: string; stderr: string }
13
14	export const runCommand = (command: string, args: string[], options: RunOptions = {}): Promise<number> => {	2!
15	return new Promise((resolve, reject) => {	×
16	const child = spawn(command, args, {	×
17	cwd: options.cwd,
18	env: { ...process.env, ...(options.env ?? {}) },	×
19	stdio: options.stdio ?? 'inherit',	×
20	shell: false,
21	})
22
23	const timer =
24	typeof options.timeoutMs === 'number'	×
25	? setTimeout(() => {
26	child.kill('SIGTERM')	×
27	}, options.timeoutMs)
28	: undefined
29
30	child.on('error', reject)	×
31	child.on('close', (code) => {	×
32	if (timer) {	×
33	clearTimeout(timer)	×
34	}
35
36	resolve(code ?? 1)	×
37	})
38	})
39	}
40
41	export const runCommandWithOutput = (	2✔
42	command: string,
43	args: string[],
44	options: RunOptions = {},	×
45	): Promise<CommandResult> => {
NEW 46	return new Promise((resolve) => {	×
47	let stdout = ''	×
48	let stderr = ''	×
NEW 49	let timedOut = false	×
NEW 50	let settled = false	×
51
NEW 52	const settle = (result: CommandResult) => {	×
NEW 53	if (!settled) {	×
NEW 54	settled = true	×
NEW 55	resolve(result)	×
56	}
57	}
58
59	const child = spawn(command, args, {	×
60	cwd: options.cwd,
61	env: { ...process.env, ...(options.env ?? {}) },	×
62	stdio: 'pipe',
63	shell: false,
64	})
65
66	const timer =
67	typeof options.timeoutMs === 'number'	×
68	? setTimeout(() => {
NEW 69	timedOut = true	×
UNCOV 70	child.kill('SIGTERM')	×
71	}, options.timeoutMs)
72	: undefined
73
74	child.stdout.on('data', (chunk) => {	×
75	stdout += chunk.toString()	×
76	})
77
78	child.stderr.on('data', (chunk) => {	×
79	stderr += chunk.toString()	×
80	})
81
NEW 82	child.on('error', (err: NodeJS.ErrnoException) => {	×
NEW 83	if (timer) { clearTimeout(timer) }	×
NEW 84	if (err.code === 'ENOENT') {	×
NEW 85	settle({ ok: false, reason: 'not-found', stdout, stderr })	×
NEW 86	} else if (err.code === 'EACCES') {	×
NEW 87	settle({ ok: false, reason: 'permission-denied', stdout, stderr })	×
88	} else {
NEW 89	settle({ ok: false, reason: 'spawn-error', stdout, stderr })	×
90	}
91	})
92
NEW 93	child.on('close', (code, signal) => {	×
NEW 94	if (timer) { clearTimeout(timer) }	×
95
NEW 96	if (timedOut) {	×
NEW 97	settle({ ok: false, reason: 'timeout', stdout, stderr })	×
NEW 98	return	×
99	}
100
NEW 101	if (signal !== null && code === null) {	×
NEW 102	settle({ ok: false, reason: 'signal', stdout, stderr })	×
NEW 103	return	×
104	}
105
NEW 106	settle({ ok: true, code: code ?? 1, stdout, stderr })	×
107	})
108	})
109	}

cameri / nostream / 25285777631

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous