yaoyao/tests/live/profileComputer.live.test.ts

// @vitest-environment node
import {expect,it} from 'vitest'
import {createServer} from 'node:http'
import {existsSync} from 'node:fs'
import {spawn} from 'node:child_process'
import {DatabaseSync} from 'node:sqlite'
import {mkdtemp,mkdir,cp,writeFile,readFile,rm} from 'node:fs/promises'
import {tmpdir} from 'node:os'
import {join,resolve} from 'node:path'
import {randomUUID} from 'node:crypto'
import {ComputerGateway,ComputerRuntime} from '../../src/runner/worker/gateway'
import {HermesBridgeManager} from '../../src/server/hermesBridge'
import {UpstreamClient} from '../../src/server/upstream'
import {UpstreamServiceSession} from '../../src/server/localAuth'

const scanner=process.env.YAOYAO_TIRITH_BIN??resolve(process.env.YAOYAO_HERMES_SOURCE??'.','../bin/tirith')
const available=['YAOYAO_HERMES_PYTHON','YAOYAO_HERMES_SOURCE','YAOYAO_COMPUTER_IMAGE'].every(name=>!!process.env[name])&&existsSync(scanner)
it.skipIf(!available).each(['profile','isolated'] as const)('runs a real Hermes %s session with native skills, authorized files, images and a real Docker VM without a Worker',async(mode)=>{
 const home=await mkdtemp(join(tmpdir(),'yaoyao-profile-live-')),workspace=join(home,'workspace'),db=new DatabaseSync(':memory:')
 await mkdir(workspace);await mkdir(join(home,'plugins'))
 await cp(resolve('integrations/hermes-bots-bridge'),join(home,'plugins','yaoyao-bot-bridge'),{recursive:true})
 await writeFile(join(workspace,'AGENTS.md'),'PROFILE_CONTEXT_MARKER: use only the fixture files and the assigned test virtual machine.\n')
 await writeFile(join(home,'SOUL.md'),'PROFILE_SOUL_MARKER: a fixture identity for ordinary Profile sessions.\n')
 const skill=join(home,'skills','authorized-fixture');await mkdir(skill,{recursive:true})
 await writeFile(join(skill,'SKILL.md'),'---\nname: authorized-fixture\ndescription: Read the authorized fixture using the native Hermes environment.\n---\nUse scripts from this directory through Hermes terminal.\n')
 await writeFile(join(workspace,'authorized.txt'),'authorized-profile-file')
 await writeFile(join(skill,'check.py'),"from pathlib import Path\nimport os\nassert os.environ.get('YAOYAO_AUTHORIZED_FIXTURE') == 'profile-env-marker'\nassert Path('authorized.txt').read_text() == 'authorized-profile-file'\nprint('native-skill-authorized-proof')\n")
 await writeFile(join(home,'.env'),'YAOYAO_AUTHORIZED_FIXTURE=profile-env-marker\n')
 const image='iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAQAAAC1HAwCAAAAC0lEQVR42mP8/x8AAwMCAO+jFz8AAAAASUVORK5CYII='
 const requests:any[]=[],results:any[]=[]
 let step=0
 const model=createServer(async(req,res)=>{
  let body='';for await(const part of req)body+=part
  res.setHeader('Content-Type','application/json')
  if(req.method==='GET'){res.end(JSON.stringify({data:[{id:'fixture-profile-model',context_length:65536}]}));return}
  const input=JSON.parse(body);requests.push(input)
  const tools=input.tools??[];let tool:string|undefined,args:any
  if(tools.length){
   results.push(...input.messages.filter((m:any)=>m.role==='tool'))
   const operation=[['skill_view',{name:'authorized-fixture'}],['terminal',{command:`python3 '${skill}/check.py'`,timeout:10}],['yaoyao_computer_copy_file_',{from:'host',source:join(workspace,'authorized.txt'),destination:'authorized.txt'}],['yaoyao_computer_shell_',{command:'cat authorized.txt > proof.txt; printf vm-profile-proof >> proof.txt; uname -s'}],['yaoyao_computer_read_file_',{path:'proof.txt'}],['yaoyao_computer_copy_file_',{from:'vm',source:'proof.txt',destination:join(workspace,'result.txt')}]][step]
   if(operation){tool=tools.find((t:any)=>t.function.name===operation[0]||t.function.name.startsWith(operation[0]))?.function.name;args=operation[1];if(tool)step++}
  }
  const message=tool?{role:'assistant',content:null,tool_calls:[{id:randomUUID(),type:'function',function:{name:tool,arguments:JSON.stringify(args)}}]}:{role:'assistant',content:tools.length?'本机与虚拟机协作完成':'fixture'}
  if(input.stream){res.setHeader('Content-Type','text/event-stream');res.end('data: '+JSON.stringify({id:randomUUID(),object:'chat.completion.chunk',model:'fixture-profile-model',choices:[{index:0,delta:message,finish_reason:tool?'tool_calls':'stop'}]})+'\n\ndata: [DONE]\n\n')}
  else res.end(JSON.stringify({id:randomUUID(),object:'chat.completion',model:'fixture-profile-model',choices:[{index:0,message,finish_reason:tool?'tool_calls':'stop'}],usage:{prompt_tokens:100,completion_tokens:30,total_tokens:130}}))
 })
 await new Promise<void>(done=>model.listen(0,'127.0.0.1',done))
 const modelURL=`http://127.0.0.1:${(model.address() as {port:number}).port}/v1`
 await writeFile(join(home,'config.yaml'),JSON.stringify({model:{default:'fixture-profile-model',provider:'custom',base_url:modelURL,api_key:'fixture',context_length:65536,max_tokens:4096,supports_vision:true},terminal:{cwd:workspace},plugins:{enabled:['yaoyao-bot-bridge']},toolsets:['all'],tools:{tool_search:{enabled:'off'}},dashboard:{turn_isolation:false},security:{tirith_path:scanner,tirith_fail_open:false},compression:{enabled:false},memory:{memory_enabled:false,user_profile_enabled:false}}))
 const reservation=createServer();await new Promise<void>(done=>reservation.listen(0,'127.0.0.1',done))
 const port=(reservation.address() as {port:number}).port;await new Promise<void>(done=>reservation.close(()=>done()))
 const url=new URL(`http://127.0.0.1:${port}`),source=process.env.YAOYAO_HERMES_SOURCE!,python=process.env.YAOYAO_HERMES_PYTHON!
 let logs='',completionTimer:ReturnType<typeof setTimeout>|undefined
 const child=spawn(python,['-m','hermes_cli.main','serve','--host','127.0.0.1','--port',String(port),'--skip-build','--isolated'],{cwd:workspace,env:{PATH:process.env.PATH,HOME:process.env.HOME,LANG:'en_US.UTF-8',HERMES_HOME:home,PYTHONPATH:source,HERMES_DASHBOARD_SESSION_TOKEN:'fixture-local-profile-token-123456789',HERMES_YOLO_MODE:mode==='profile'?'1':'0',NO_PROXY:'127.0.0.1,localhost'},stdio:['ignore','pipe','pipe']})
 child.stdout.on('data',c=>{logs=(logs+String(c)).slice(-16000)});child.stderr.on('data',c=>{logs=(logs+String(c)).slice(-16000)})
 const client=new UpstreamClient(url),target={url,client,session:new UpstreamServiceSession(client,()=>undefined)}
 const runtime=new ComputerRuntime(db,{protocol:1,runnerId:randomUUID(),serverURL:url.href,hermesURL:url.href,token:'fixture',allowedProfiles:['default'],artifactRoots:[],computers:{runtime:'docker',imageId:process.env.YAOYAO_COMPUTER_IMAGE!,python:'/must-not-launch-worker',hermesSource:'/must-not-read-profile',hermesHome:'/must-not-read-profile',network:'none'}},home,resolve('src/runner/worker/hermes_worker.py'),undefined,target)
 const id=randomUUID(),gateway=new ComputerGateway(runtime,{environmentId:id,agentId:id,ownerKey:'profile-live-fixture',hostAccess:mode==='profile',profileSession:mode==='profile',hermesRuntime:true},randomUUID(),async()=>{},async()=>({}),target)
 try{
  await expect.poll(async()=>{if(child.exitCode!==null)throw new Error(logs);try{return(await fetch(new URL('/api/status',url))).status}catch{return 0}},{timeout:45000}).toBe(200)
  const approvals=new Set<string>(),frames:any[]=[],answers:any[]=[]
  const complete=new Promise<any>((done,reject)=>{completionTimer=setTimeout(()=>{void readFile(join(home,'logs','agent.log'),'utf8').catch(()=>logs).then(log=>reject(new Error('Hermes fixture completion timed out\n'+JSON.stringify({step,approvals:[...approvals],frames,answers})+'\n'+log.slice(-16000))))},45000);gateway.onEvent=frame=>{
    if(!['message.delta','reasoning.delta'].includes(frame.type))frames.push(frame)
    if(frame.type==='message.complete')done(frame.payload)
    if(['approval.request','approval.requested'].includes(frame.type)){
      const id=String(frame.payload?.request_id??frame.payload?.id??'')
      if(!approvals.has(id)){approvals.add(id);void gateway.rpc('approval.respond',{session_id:frame.session_id,request_id:id,choice:'once'}).then(result=>{answers.push({id,result})},reject)}
    }
  };gateway.onDisconnect=()=>reject(new Error('Profile disconnected\n'+logs))})
  void complete.catch(()=>{})
  await gateway.connect();const opened=await gateway.rpc('session.create',{profile:'default'})
  await gateway.rpc('image.attach_bytes',{session_id:opened.session_id,filename:'fixture.png',content_base64:image})
  await gateway.rpc('prompt.submit',{session_id:opened.session_id,text:'依次执行本机终端、虚拟机命令、读取虚拟机文件，然后报告完成。'})
  const result=await complete;clearTimeout(completionTimer)
  expect(result.text,logs).toBe('本机与虚拟机协作完成');expect(step,JSON.stringify(requests.map(r=>r.tools?.map((t:any)=>t.function.name)))).toBe(6)
  expect(JSON.stringify(results)).toContain('native-skill-authorized-proof');expect(JSON.stringify(results)).toContain('vm-profile-proof');expect(JSON.stringify(results)).toContain('Linux')
  const modelMessages=JSON.stringify(requests.filter(r=>r.tools?.length).map(r=>r.messages))
  for(const marker of ['PROFILE_CONTEXT_MARKER','PROFILE_SOUL_MARKER']){
    if(mode==='profile')expect(modelMessages).toContain(marker)
    else expect(modelMessages).not.toContain(marker)
  }
  expect(JSON.stringify(requests.filter(r=>r.tools?.length).map(r=>r.messages))).toContain(image)
  expect(JSON.stringify(results)).toContain('authorized-profile-file')
  expect(await readFile(join(workspace,'result.txt'),'utf8')).toBe('authorized-profile-filevm-profile-proof')
  expect(await runtime.extractMemory('default','只保留给定事实：测试已完成')).toBe('fixture')
  if(mode==='profile'){
    const assets=join(home,'install-package');await mkdir(assets)
    await cp(resolve('integrations/hermes-bots-bridge'),join(assets,'hermes-bots-bridge'),{recursive:true})
    await cp(resolve('scripts/install-hermes-bridge.py'),join(assets,'install-hermes-bridge.py'))
    const manager=new HermesBridgeManager({upstream:url} as any,target.session,{home,python,assetsRoot:assets})
    expect((await manager.status()).profiles.find(p=>p.profile==='default')?.state).toBe('ready')
    const bundled=join(assets,'hermes-bots-bridge','bridge_runtime.py')
    await writeFile(bundled,(await readFile(bundled,'utf8'))+'\n# Updated fixture package\n')
    expect((await manager.status()).profiles.find(p=>p.profile==='default')?.state).toBe('outdated')
    const installed=await manager.install({profile:'default'})
    expect(installed.status.profiles.find(p=>p.profile==='default')?.state).toBe('restart-required')
    expect(installed.backup).toContain(home)
  }
  if(mode==='isolated')expect(approvals.size).toBeGreaterThanOrEqual(3)
  expect(runtime.workers.size).toBe(0)
 }finally{
  clearTimeout(completionTimer)
  await gateway.close().catch(()=>{});await runtime.controls.close();await runtime.pool.close();db.close();client.close()
  child.kill('SIGTERM');await new Promise<void>(done=>{if(child.exitCode!==null){done();return}const timer=setTimeout(()=>child.kill('SIGKILL'),5000);child.once('exit',()=>{clearTimeout(timer);done()})})
  await new Promise<void>(done=>{model.close(()=>done());model.closeAllConnections()});await rm(home,{recursive:true,force:true})
 }
},120000)