scriptoriumadmin/skillhub
1
0
Fork 0
mirror of https://github.com/iflytek/skillhub.git synced 2026-10-15 04:18:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

test(cli): synchronize stale lock contenders

Browse source 
Signed-off-by: XiaoSeS <87064762+XiaoSeS@users.noreply.github.com>
This commit is contained in:
XiaoSeS 2026-09-01 21:50:35 +08:00
parent 80c31a5bb7
commit 2c80b720b5
2 changed files with 18 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
cli/test/helpers/target-lock-worker.ts
View file

@ -2,10 +2,20 @@ import { access, writeFile } from 'node:fs/promises'
import { acquireSkillTargetLock } from '../../src/services/skill-target-lock'
import { CliError } from '../../src/shared/errors'
const [rootDir, slug, acquiredPath, releasePath] = process.argv.slice(2)
if (!rootDir || !slug || !acquiredPath || !releasePath) process.exit(5)
const [rootDir, slug, readyPath, startPath, acquiredPath, releasePath] = process.argv.slice(2)
if (!rootDir || !slug || !readyPath || !startPath || !acquiredPath || !releasePath) process.exit(5)
try {
await writeFile(readyPath, 'ready')
let startRequested = false
while (!startRequested) {
try {
await access(startPath)
startRequested = true
} catch {
await new Promise(resolve => setTimeout(resolve, 10))
}
}
const release = await acquireSkillTargetLock(rootDir, slug)
await writeFile(acquiredPath, 'acquired')
process.stdout.write('acquired\n')

8
cli/test/unit/services/skill-target-lock.test.ts
View file

@ -69,13 +69,17 @@ describe('skill target lifecycle lock', () => {
const bunPath = (await Bun.which('bun')) ?? process.execPath
const acquiredPath = join(rootDir, 'acquired')
const releasePath = join(rootDir, 'release')
const startPath = join(rootDir, 'start')
const readyPaths = [join(rootDir, 'ready-0'), join(rootDir, 'ready-1')]
const processes = [0, 1].map(() => Bun.spawn({
cmd: [bunPath, worker, rootDir, 'demo', acquiredPath, releasePath],
const processes = readyPaths.map(readyPath => Bun.spawn({
cmd: [bunPath, worker, rootDir, 'demo', readyPath, startPath, acquiredPath, releasePath],
stdout: 'pipe',
stderr: 'pipe'
}))
try {
await Promise.all(readyPaths.map(waitForFile))
await writeFile(startPath, 'start')
await waitForFile(acquiredPath)
const loserExitCode = await Promise.race([
...processes.map(process => process.exited),