@@ -10,7 +10,11 @@ import { createDurableResourceEnvelope } from '@agent-device/capture-kit';
1010import { localRuntimeOwner } from '@agent-device/contracts/platform-runtime' ;
1111import { runStaleDeviceClaimRelease } from '../platform-runtime-claim-recovery.ts' ;
1212import { runCliCapture } from './cli-capture.ts' ;
13- import { mkdtempForTestSync , pinOwnProcessStartTime } from '@agent-device/test-kit' ;
13+ import {
14+ createLiveTestHostEnvironment ,
15+ mkdtempForTestSync ,
16+ pinOwnProcessStartTime ,
17+ } from '@agent-device/test-kit' ;
1418
1519pinOwnProcessStartTime ( hostProcess ) ;
1620
@@ -283,16 +287,20 @@ test('recovery is composed per claim from the stale owner state dir, never the c
283287 process . env . AGENT_DEVICE_CLAIMS_DIR = claimsDir ;
284288
285289 const composedFor : string [ ] = [ ] ;
286- const outcomes = await runStaleDeviceClaimRelease ( { } , process . env , ( stateDir ) => {
287- composedFor . push ( stateDir ) ;
288- return {
289- reconcile : async ( claim ) => {
290- assert . equal ( claim . stateDir , stateDir ) ;
291- return { status : 'reconciled' } ;
292- } ,
293- dispose : async ( ) => { } ,
294- } ;
295- } ) ;
290+ const outcomes = await runStaleDeviceClaimRelease (
291+ { } ,
292+ createLiveTestHostEnvironment ( ) ,
293+ ( stateDir ) => {
294+ composedFor . push ( stateDir ) ;
295+ return {
296+ reconcile : async ( claim ) => {
297+ assert . equal ( claim . stateDir , stateDir ) ;
298+ return { status : 'reconciled' } ;
299+ } ,
300+ dispose : async ( ) => { } ,
301+ } ;
302+ } ,
303+ ) ;
296304
297305 assert . deepEqual ( [ ...composedFor ] . sort ( ) , [ ownerDirA , ownerDirB ] . sort ( ) ) ;
298306 assert . equal ( outcomes . filter ( ( outcome ) => outcome . status === 'released' ) . length , 2 ) ;
0 commit comments