34 lines
2.4 KiB
JavaScript
34 lines
2.4 KiB
JavaScript
import { test } from 'node:test';
|
|
import assert from 'node:assert/strict';
|
|
import { readFileSync, writeFileSync } from 'node:fs';
|
|
import { spawnSync } from 'node:child_process';
|
|
import { join } from 'node:path';
|
|
import { tmp } from './helpers.mjs';
|
|
import { instrumentInnerTimer, removeInnerObservers, readProbeSeconds } from './case-inner-timing-fixture.mjs';
|
|
const scripts=['case1-accept.sh','case2-unit.sh'];
|
|
const read=name=>readFileSync(new URL(`../../../scripts/${name}`,import.meta.url),'utf8');
|
|
for(const name of scripts)test(`inner timing ${name}: private copy preserves shipped bytes and rejects anchor drift`,t=>{
|
|
const clock=join(tmp(t,'timer-'),'clock');
|
|
const source=read(name),copy=instrumentInnerTimer(source,clock);
|
|
assert.equal(removeInnerObservers(copy,clock),read(name));
|
|
for(const marker of ['SO_PEERCRED','MOSAIC_TESTER_SOCKET_V1','MOSAIC_LEGACY_STATUS'])
|
|
assert.equal(copy.split(marker).length,source.split(marker).length,marker);
|
|
for(const anchor of ['# row253-supervisor-begin\n','# row253-supervisor-end\n','"$sleep_bin" "$seconds" & timer=$!\n','finish() {\n local rc="$?"\n']){
|
|
assert.throws(()=>instrumentInnerTimer(source.replace(anchor,''),clock),/anchor/);
|
|
assert.throws(()=>instrumentInnerTimer(source.replace(anchor,anchor+anchor),clock),/anchor/);
|
|
}
|
|
});
|
|
for(const name of scripts)test(`inner timing ${name}: real supervisor retains streams status and EXIT cleanup`,t=>{
|
|
const clock=join(tmp(t,'timer-'),"clock '$;literal");writeFileSync(clock,'');
|
|
const source=instrumentInnerTimer(read(name),clock);
|
|
const body=source.slice(source.indexOf('# row253-supervisor-begin'),source.indexOf('# row253-supervisor-end'));
|
|
const result=spawnSync('/bin/bash',['-c',body+'\n/bin/bash -c "$TESTER_SUPERVISOR" -- 2 /usr/bin/setsid /usr/bin/sleep /bin/bash -c \'printf exact-out; printf exact-err >&2; /usr/bin/sleep 0.1; exit 7\''],{encoding:'utf8'});
|
|
assert.equal(result.status,87,result.stderr);
|
|
assert.equal(result.stdout,'exact-out');assert.equal(result.stderr,'exact-err');
|
|
assert.match(readFileSync(clock,'utf8'),/^begin [0-9]+\.[0-9]{2}\nend [0-9]+\.[0-9]{2}\n$/);
|
|
// The same strict parser used by the timing bands rejects a guard's partial,
|
|
// duplicate or reversed pair, rather than substituting wall time.
|
|
for(const invalid of ['begin 10.00\n','end 11.00\n','begin 10.00\nend 11.00\nbegin 12.00\nend 13.00\n','begin 11.00\nend 10.00\n'])
|
|
assert.throws(()=>readProbeSeconds(invalid));
|
|
});
|