runner.test.ts 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407
  1. // @vitest-environment node
  2. import { afterEach, beforeEach, expect, it, vi } from 'vitest'
  3. import Koa from 'koa'
  4. import { createServer, type Server } from 'node:http'
  5. import { mkdtempSync, rmSync, writeFileSync } from 'node:fs'
  6. import { spawn } from 'node:child_process'
  7. import { once } from 'node:events'
  8. import { tmpdir } from 'node:os'
  9. import { join } from 'node:path'
  10. import { randomUUID } from 'node:crypto'
  11. import { WebSocketServer, type WebSocket } from 'ws'
  12. import { WorkspaceStore } from '../../src/server/workspaceStore'
  13. import { LocalAuthStore } from '../../src/server/localAuth'
  14. import { RunnerHub } from '../../src/server/runnerHub'
  15. import { RunnerAgent } from '../../src/runner/agent'
  16. import { ComputerGateway } from '../../src/runner/worker/gateway'
  17. import { WorkspaceGateway, type GatewayTarget, type GatewayFrame } from '../../src/server/workspaceGateway'
  18. import { createWorkspaceToolLease } from '../../src/server/workspaceToolLease'
  19. import { HttpError } from '../../src/server/errors'
  20. import type { RunnerCommand, RunnerConfiguration } from '../../src/shared/runner'
  21. class Auth extends LocalAuthStore {
  22. version=1
  23. allowed=true
  24. override isUserActive(){return true}
  25. override pushAuthorizationVersion(){return this.version}
  26. override canUseSource(){return this.allowed}
  27. }
  28. let home:string,store:WorkspaceStore,auth:Auth,hub:RunnerHub,runner:RunnerAgent,config:RunnerConfiguration
  29. let web:Server,hermes:Server,ws:WebSocketServer,controller:AbortController,running:Promise<void>
  30. let target:GatewayTarget,bindings:any[],rpc:Array<{method:string;params:any}>,frames:GatewayFrame[],sockets:WebSocket[]
  31. const gateways:WorkspaceGateway[]=[]
  32. const listen=(server:Server)=>new Promise<string>(resolve=>server.listen(0,'127.0.0.1',()=>resolve(`http://127.0.0.1:${(server.address() as {port:number}).port}`)))
  33. const close=(server:Server)=>new Promise<void>(resolve=>{server.close(()=>resolve());server.closeAllConnections()})
  34. beforeEach(async()=>{
  35. home=mkdtempSync(join(tmpdir(),'yaoyao-runner-'));store=new WorkspaceStore(home);auth=new Auth(home)
  36. bindings=[];rpc=[];frames=[];sockets=[]
  37. hermes=createServer(async(req,res)=>{
  38. let body='';for await(const part of req)body+=part
  39. if(req.url?.endsWith('/bind'))bindings.push(JSON.parse(body))
  40. res.setHeader('Content-Type','application/json')
  41. res.end(JSON.stringify(req.url==='/api/auth/ws-ticket'?{ticket:'fixture'}:req.url==='/api/profiles'?{profiles:['default',{name:'writer'},{name:'secret'}]}:req.url?.endsWith('/capabilities')?{version:1,ready:true,in_process:true,native_tools:true}:{ok:true,native_tools:true,workspace_memory:body?JSON.parse(body).workspace_memory===true:false,terminal:{cwd:'/fixture/workspace'}}))
  42. })
  43. const hermesURL=await listen(hermes)
  44. ws=new WebSocketServer({server:hermes})
  45. ws.on('connection',socket=>{
  46. sockets.push(socket);socket.send(JSON.stringify({method:'event',params:{type:'gateway.ready'}}))
  47. socket.on('message',raw=>{
  48. const value=JSON.parse(String(raw));rpc.push(value)
  49. const result=['session.create','session.resume'].includes(value.method)?{session_id:randomUUID(),stored_session_id:randomUUID(),info:{profile_name:value.params.profile}}:value.method==='session.active_list'?{sessions:[{id:value.params.current_session_id,status:'idle',title:'owned'},{id:'unowned',status:'working',title:'private'}]}:{ok:true}
  50. socket.send(JSON.stringify({id:value.id,result}))
  51. })
  52. })
  53. hub=new RunnerHub(store,auth,{url:new URL(hermesURL)} as GatewayTarget)
  54. const registered=hub.enroll('owner',{name:'测试电脑',allowedProfiles:['default','writer']})
  55. const app=new Koa();app.use(async(ctx,next)=>{try{await next()}catch(error){ctx.status=error instanceof HttpError?error.status:500;ctx.body={code:error instanceof HttpError?error.code:'error'}}});app.use(hub.middleware())
  56. web=createServer(app.callback());const serverURL=await listen(web)
  57. config={protocol:1,serverURL,runnerId:registered.runner.id,token:registered.token,hermesURL,allowedProfiles:['default','writer'],artifactRoots:[]}
  58. runner=new RunnerAgent(config,home);controller=new AbortController();running=runner.run(controller.signal);void running.catch(()=>{})
  59. await vi.waitFor(()=>expect(hub.summary(hub.records()[0]!).online).toBe(true))
  60. await vi.waitFor(()=>expect((runner as any).serverEpoch).toBeTruthy())
  61. target=hub.target('owner','local')!
  62. })
  63. afterEach(async()=>{
  64. for(const gateway of gateways.splice(0))gateway.close()
  65. controller.abort();await running.catch(()=>{});hub.close()
  66. for(const socket of ws.clients)socket.terminate()
  67. await new Promise<void>(resolve=>ws.close(()=>resolve()));await close(hermes);await close(web)
  68. store.close();rmSync(home,{recursive:true,force:true})
  69. })
  70. async function channel(){
  71. const gateway=new WorkspaceGateway(target);gateways.push(gateway);gateway.onEvent=frame=>frames.push(frame)
  72. await gateway.connect();const session=await gateway.rpc('session.create',{profile:'default'})
  73. return {gateway,session}
  74. }
  75. it('blocks old Runner control paths when the global VM proxy is enabled',async()=>{
  76. hub.executionSettings={proxy:()=>({enabled:true,revision:1})} as any
  77. hub.controlAllowed=()=>true
  78. for(const payload of [{op:'take'},{op:'input'},{op:'autostart'},{op:'lifecycle',action:'start'}])await expect((hub as any).request(config.runnerId,'computer.control',payload)).rejects.toMatchObject({code:'proxy_runner_required'})
  79. expect(await (runner as any).api('control-check',{controlId:randomUUID()})).toEqual({allowed:false})
  80. expect((hub as any).networkCommandAllowed(config.runnerId,'computer.control',{op:'lifecycle',action:'stop'})).toBe(true)
  81. })
  82. it('reports missing network prerequisites for saved proxy settings and clears the error after applying them',async()=>{
  83. hub.executionSettings={proxy:()=>({enabled:true,revision:4})} as any
  84. ;(hub as any).online.get(config.runnerId).features.push('vm-egress-v1')
  85. const request=vi.spyOn(hub as any,'request').mockRejectedValue(new HttpError(502,'private transport details','computer_network_upgrade_required'))
  86. try{
  87. await hub.configureNetworks()
  88. expect(hub.networkStatus()[0]?.status).toContain('缺少虚拟机网络网关')
  89. const result=await hub.testNetworks()
  90. expect(result.nodes[0]).toMatchObject({ok:false,error:expect.stringContaining('重新准备网络镜像')})
  91. expect(JSON.stringify(result)).not.toContain('private transport details')
  92. request.mockRejectedValue(new Error('http://user:secret@proxy.invalid'))
  93. expect(JSON.stringify(await hub.testNetworks())).not.toContain('secret')
  94. request.mockResolvedValue({revision:4})
  95. await hub.configureNetworks()
  96. expect(hub.networkStatus()[0]?.status).toBe('已同步,启动时校验出口')
  97. }finally{request.mockRestore()}
  98. })
  99. it('does not report a successful VM proxy test when the network gateway is missing',async()=>{
  100. hub.executionSettings={proxy:()=>({enabled:true,revision:4})} as any
  101. const verifyNetwork=vi.fn().mockRejectedValue(new HttpError(409,'缺少网络网关','computer_network_upgrade_required'))
  102. const original=(runner as any).computers
  103. ;(runner as any).computers={provider:{verifyNetwork},config:{imageId:'sha256:'+'a'.repeat(64)}}
  104. try{
  105. await expect((runner as any).execute({kind:'network.test',payload:{}})).rejects.toMatchObject({code:'computer_network_upgrade_required'})
  106. expect(verifyNetwork).toHaveBeenCalledOnce()
  107. }finally{(runner as any).computers=original}
  108. })
  109. it('admits virtual computer calls only on a computer gateway with an owned session',async()=>{
  110. const connectionId=randomUUID(),sessionId=randomUUID(),rpc=vi.fn(async()=>({ok:true}))
  111. const computer=Object.assign(Object.create(ComputerGateway.prototype),{rpc,close:()=>{}}) as ComputerGateway
  112. const connection={gateway:computer,sessions:new Map([[sessionId,'default']]),running:new Set(),events:Promise.resolve()}
  113. ;(runner as any).connections.set(connectionId,connection)
  114. const command=(method:string,id=sessionId)=>({kind:'gateway.rpc',payload:{connectionId,method,params:{session_id:id,name:'computer_desktop_state',arguments:{}}}})
  115. expect(await (runner as any).execute(command('computer.invoke'))).toEqual({ok:true})
  116. expect(await (runner as any).execute(command('computer.transfer'))).toEqual({ok:true})
  117. expect(await (runner as any).execute(command('computer.complete'))).toEqual({ok:true})
  118. await expect((runner as any).execute(command('computer.invoke',randomUUID()))).rejects.toMatchObject({code:'runner_session_forbidden'})
  119. await expect((runner as any).execute(command('computer.complete',randomUUID()))).rejects.toMatchObject({code:'runner_session_forbidden'})
  120. connection.gateway=Object.assign(Object.create(WorkspaceGateway.prototype),{rpc,close:()=>{}}) as ComputerGateway
  121. await expect((runner as any).execute(command('computer.invoke'))).rejects.toMatchObject({code:'runner_command_forbidden'})
  122. await expect((runner as any).execute(command('computer.complete'))).rejects.toMatchObject({code:'runner_command_forbidden'})
  123. expect(rpc).toHaveBeenCalledTimes(3)
  124. })
  125. it('waits for local VM recovery before restoring a saved desktop and skips unconfigured targets',async()=>{
  126. const original=(runner as any).computers,oldManager=(runner as any).localVm,id=randomUUID()
  127. const sync=vi.spyOn(runner as any,'syncNetworkSettings').mockResolvedValue(undefined)
  128. let ready!:()=>void
  129. const definition=vi.fn(()=>({id})),restoreDesktop=vi.fn(async(_target:any,authorize:()=>void)=>authorize())
  130. ;(runner as any).computers={ready:Promise.resolve(),pool:{definition},restoreDesktop}
  131. ;(runner as any).localVm={ready:new Promise<void>(done=>{ready=done})}
  132. const command={kind:'computer.control',expiresAt:Date.now()+30000,payload:{target:{environmentId:id,agentId:id,ownerKey:'a'.repeat(64)},profile:'default',op:'autostart'}}
  133. try{
  134. const pending=(runner as any).execute(command)
  135. await Promise.resolve();expect(restoreDesktop).not.toHaveBeenCalled()
  136. ready();await pending
  137. expect(sync).toHaveBeenCalledOnce();expect(restoreDesktop).toHaveBeenCalledWith(command.payload.target,expect.any(Function))
  138. definition.mockReturnValue(undefined as any)
  139. expect(await (runner as any).execute(command)).toMatchObject({skipped:true})
  140. expect(restoreDesktop).toHaveBeenCalledOnce()
  141. }finally{ready();sync.mockRestore();(runner as any).computers=original;(runner as any).localVm=oldManager}
  142. })
  143. it('requires an upgraded Runner before granting mixed host and VM tools',()=>{
  144. const id=randomUUID()
  145. expect(()=>hub.target('owner','local',{environmentId:id,agentId:id,ownerKey:'owner',hostAccess:true})).toThrow('不支持同时使用本机和虚拟机')
  146. })
  147. it('distinguishes a missing or disabled VM runner, an offline runner and incompatible features',async()=>{
  148. const agent=store.createAgent('owner',{name:'虚拟机状态',profile:'default'})
  149. expect(()=>hub.computerRunner('owner',agent)).toThrow('请启用隔离电脑 Worker 或更新 Runner')
  150. controller.abort();await running
  151. const record=hub.records()[0]!
  152. hub.remove(record.id)
  153. expect(()=>hub.computerRunner('owner',agent)).toThrow('本地虚拟机执行节点尚未启用')
  154. store.put('_system','runner',record.id,{...record,enabled:true})
  155. expect(()=>hub.computerRunner('owner',agent)).toThrow('本地虚拟机执行节点未连接')
  156. store.remove('_system','runner',record.id)
  157. expect(()=>hub.computerRunner('owner',agent)).toThrow('本地虚拟机执行节点尚未启用')
  158. })
  159. it('rejects Profile collaboration on a Runner that does not advertise the execution backend',()=>{
  160. const id=randomUUID()
  161. expect(()=>hub.target('owner','local',{environmentId:id,agentId:id,ownerKey:'owner',hostAccess:true,profileSession:true})).toThrow('不支持本机协作模式')
  162. })
  163. it.each([false,true])('admits Profile collaboration after an actual computer Runner handshake (Compose: %s)',async compose=>{
  164. controller.abort();await running
  165. config.computers={runtime:'docker',imageId:'sha256:'+'0'.repeat(64),python:'/fixture/python',hermesSource:home,hermesHome:home,...(compose?{managedBy:'compose' as const}:{})}
  166. runner=new RunnerAgent(config,home);controller=new AbortController();running=runner.run(controller.signal);void running.catch(()=>{})
  167. await vi.waitFor(()=>expect((runner as any).serverEpoch).toBeTruthy())
  168. const features=hub.summary(hub.records()[0]!).features
  169. expect(features).toContain('profile-computer-v1')
  170. expect(features).toEqual(expect.arrayContaining(['host-computer-tools-v1','computer-worker-v1','computer-control-v1']))
  171. if(compose)expect(features).toContain('compose-desktops-v1')
  172. const agent=store.createAgent('owner',{name:'协作握手',profile:'default',computer:'vm',execution:'computer',vmExecution:'profile'})
  173. expect(()=>hub.target('owner','local',{agentId:agent.id,environmentId:agent.id,ownerKey:'owner',hostAccess:true,profileSession:true})).not.toThrow()
  174. })
  175. async function machine(path:string,body?:unknown,overrides:Record<string,string>={}){
  176. return fetch(`${config.serverURL}/api/runner/v1/${config.runnerId}/${path}`,{
  177. method:body===undefined?'GET':'POST',headers:{Authorization:`Bearer ${config.token}`,'x-runner-instance':runner.instance,'x-runner-protocol':'1','x-runner-epoch':(runner as any).serverEpoch,'Content-Type':'application/json',...overrides},...(body===undefined?{}:{body:JSON.stringify(body)})
  178. })
  179. }
  180. it('connects through outbound transport, filters profiles and forwards only owned session events',async()=>{
  181. const profiles=await target.session.request('/api/profiles')
  182. expect(JSON.parse(profiles.body.toString()).profiles).toEqual(['default',{name:'writer'}])
  183. const {gateway,session}=await channel()
  184. await expect(gateway.rpc('session.create',{profile:'secret'})).rejects.toMatchObject({code:'runner_profile_forbidden'})
  185. await expect(gateway.rpc('prompt.submit',{session_id:'someone-else',text:'no'})).rejects.toMatchObject({code:'runner_session_forbidden'})
  186. await gateway.rpc('prompt.submit',{session_id:session.session_id,text:'hello'})
  187. sockets[0]!.send(JSON.stringify({method:'event',params:{type:'message.delta',session_id:'someone-else',payload:{text:'private'}}}))
  188. sockets[0]!.send(JSON.stringify({method:'event',params:{type:'message.delta',session_id:session.session_id,payload:{text:'hello'}}}))
  189. await vi.waitFor(()=>expect(frames.some(f=>f.payload?.text==='hello')).toBe(true))
  190. expect(frames.some(f=>f.payload?.text==='private')).toBe(false)
  191. })
  192. it('mounts loopback-only tools with stable call ids and revokes an active grant',async()=>{
  193. const {session}=await channel(),abort=new AbortController(),call=vi.fn(async()=>({agent:{id:'created'}}))
  194. let active=true
  195. const lease=await createWorkspaceToolLease({target,profile:'default',workId:'work',session:()=>({runtimeId:session.session_id,storedId:session.stored_session_id}),signal:abort.signal,
  196. assertActive:()=>{if(!active)throw new HttpError(403,'撤权','revoked')},catalog:()=>[{id:'workspace_create_agent',name:'workspace_create_agent',description:'create',inputSchema:{type:'object'}}],call,onFailure:()=>{}})
  197. await lease.bind();const binding=bindings[0]
  198. const toolHTTP=(path:string,body:unknown)=>fetch(binding.bridge_url+path,{method:'POST',headers:{Authorization:`Bearer ${binding.token}`,'Content-Type':'application/json'},body:JSON.stringify(body)})
  199. const catalog=await (await toolHTTP('/tools/list',{})).json() as any
  200. const body={callId:'same-call',toolId:catalog.tools[0].id,arguments:{name:'worker'}}
  201. const first=await (await toolHTTP('/tools/call',body)).json()
  202. expect(await (await toolHTTP('/tools/call',body)).json()).toEqual(first)
  203. expect(call).toHaveBeenCalledExactlyOnceWith('workspace_create_agent',{name:'worker'},'same-call')
  204. active=false
  205. expect(await (await toolHTTP('/tools/call',{...body,callId:'late-call'})).json()).toMatchObject({isError:true})
  206. expect(call).toHaveBeenCalledTimes(1)
  207. await lease.dispose()
  208. })
  209. it('denies browser credentials, stale epochs, foreign lease ids and unauthorized HTTP operations',async()=>{
  210. expect((await machine('admit',{id:randomUUID()},{Origin:config.serverURL})).status).toBe(403)
  211. expect((await machine('admit',{id:randomUUID()},{Authorization:'Bearer wrong'})).status).toBe(403)
  212. expect((await machine('admit',{id:randomUUID()},{'x-runner-epoch':'old'})).status).toBe(409)
  213. expect((await machine('tool',{leaseId:randomUUID(),callId:'test',toolId:'workspace_create_agent',arguments:{}})).status).toBe(410)
  214. await expect(target.session.request('/api/config',{method:'POST',body:{}})).rejects.toMatchObject({code:'runner_http_forbidden'})
  215. await expect(target.session.request('/api/files/download',{search:new URLSearchParams({profile:'default',path:'/etc/hosts'})})).rejects.toMatchObject({code:'runner_artifact_forbidden'})
  216. })
  217. it('does not execute a queued command after account authorization changes',async()=>{
  218. const {gateway,session}=await channel()
  219. auth.version++
  220. await expect(gateway.rpc('prompt.submit',{session_id:session.session_id,text:'late'})).rejects.toMatchObject({code:'runner_command_not_admitted'})
  221. expect(rpc.filter(r=>r.method==='prompt.submit')).toHaveLength(0)
  222. })
  223. it('keeps one result for a command and refuses conflicting or unfinished replay after restart',async()=>{
  224. const seen:RunnerCommand[]=[];const execute=(runner as any).execute.bind(runner)
  225. vi.spyOn(runner as any,'execute').mockImplementation(async(command:any)=>{seen.push(command);return execute(command)})
  226. await channel()
  227. const command=seen.find(c=>c.kind==='gateway.rpc')!
  228. const before=rpc.length
  229. expect(await runner.handle(command)).toHaveProperty('result.session_id')
  230. expect(rpc).toHaveLength(before)
  231. await expect(runner.handle({...command,payload:{changed:true}})).rejects.toMatchObject({code:'idempotency_conflict'})
  232. const incomplete={...command,id:randomUUID()}
  233. const {createHash}=await import('node:crypto')
  234. ;(runner as any).db.prepare("INSERT INTO commands VALUES(?,?,'started',NULL,?)").run(incomplete.id,createHash('sha256').update(JSON.stringify(incomplete)).digest('hex'),Date.now())
  235. controller.abort();await running
  236. runner=new RunnerAgent(config,home);controller=new AbortController();running=runner.run(controller.signal);void running.catch(()=>{})
  237. await expect(runner.handle(incomplete)).rejects.toMatchObject({code:'runner_command_uncertain'})
  238. expect(await runner.handle(command)).toHaveProperty('result.session_id')
  239. expect(rpc).toHaveLength(before)
  240. })
  241. it('closes a pending gateway before a delayed handshake can revive it',async()=>{
  242. const connect=WorkspaceGateway.prototype.connect
  243. let release!:()=>void
  244. const gate=new Promise<void>(resolve=>{release=resolve})
  245. vi.spyOn(WorkspaceGateway.prototype,'connect').mockImplementationOnce(async function(this:WorkspaceGateway){await gate;return connect.call(this)})
  246. const connectionId=randomUUID(),request=(hub as any).request.bind(hub)
  247. // The control plane normally installs this owner record before opening.
  248. ;(hub as any).connections.set(connectionId,{runnerId:config.runnerId,valid:()=>true,onEvent:()=>{},onDisconnect:()=>{}})
  249. const opening=request(config.runnerId,'gateway.open',{connectionId}).catch((error:unknown)=>error)
  250. await vi.waitFor(()=>expect((runner as any).connections.has(connectionId)).toBe(true))
  251. await request(config.runnerId,'gateway.close',{connectionId})
  252. release()
  253. expect(await opening).toBeInstanceOf(Error)
  254. expect((runner as any).connections.has(connectionId)).toBe(false)
  255. })
  256. it('fences a replaced process and does not route to the host when its runner goes offline',async()=>{
  257. const {gateway}=await channel();const disconnected=vi.fn();gateway.onDisconnect=disconnected
  258. const oldInstance=runner.instance
  259. controller.abort();await running
  260. runner=new RunnerAgent(config,home);controller=new AbortController();running=runner.run(controller.signal);void running.catch(()=>{})
  261. await vi.waitFor(()=>expect(disconnected).toHaveBeenCalled())
  262. expect((await machine('poll',undefined,{'x-runner-instance':oldInstance})).status).toBe(409)
  263. hub.remove(config.runnerId)
  264. await expect(target.session.request('/api/status')).rejects.toMatchObject({code:'runner_offline'})
  265. })
  266. it('resets the hub epoch after a transport failure and closes the obsolete gateways',async()=>{
  267. const {gateway}=await channel(),disconnected=vi.fn();gateway.onDisconnect=disconnected
  268. const epoch=(runner as any).serverEpoch
  269. await (runner as any).disconnect()
  270. // Wake the outstanding poll. Its response must be ignored after disconnect.
  271. ;(hub as any).online.get(config.runnerId).wake?.()
  272. await vi.waitFor(()=>expect((runner as any).serverEpoch).not.toBe(epoch))
  273. expect(disconnected).toHaveBeenCalledTimes(1)
  274. const next=await channel()
  275. expect(await next.gateway.rpc('session.usage',{session_id:next.session.session_id})).toEqual({ok:true})
  276. })
  277. it('a closed account channel cannot interrupt an unrelated connection',async()=>{
  278. const first=await channel(),second=await channel()
  279. const entries=[...(hub as any).connections.entries()] as Array<[string,any]>
  280. entries[0]![1].valid=()=>false
  281. sockets[0]!.send(JSON.stringify({method:'event',params:{type:'message.delta',session_id:first.session.session_id,payload:{text:'revoked'}}}))
  282. await vi.waitFor(()=>expect((runner as any).connections.size).toBe(1))
  283. expect((runner as any).connected).toBe(true)
  284. expect(await second.gateway.rpc('prompt.submit',{session_id:second.session.session_id,text:'continue'})).toEqual({ok:true})
  285. expect(rpc.filter(r=>r.method==='session.interrupt'&&r.params.session_id===second.session.session_id)).toHaveLength(0)
  286. })
  287. it('rechecks admission after a queued prompt loses its account permission',async()=>{
  288. const {gateway,session}=await channel()
  289. const api=(runner as any).api.bind(runner)
  290. let release!:()=>void,waiting=false
  291. const gate=new Promise<void>(resolve=>{release=resolve})
  292. vi.spyOn(runner as any,'api').mockImplementation(async(path:any,body:any)=>{if(path==='admit'){waiting=true;await gate}return api(path,body)})
  293. const result=gateway.rpc('prompt.submit',{session_id:session.session_id,text:'must not run'}).catch(error=>error)
  294. await vi.waitFor(()=>expect(waiting).toBe(true));auth.version++;release()
  295. expect(await result).toMatchObject({code:'runner_command_not_admitted'})
  296. expect(rpc.filter(r=>r.method==='prompt.submit')).toHaveLength(0)
  297. })
  298. it('does not recreate a lease when cancellation overtakes its admitted creation',async()=>{
  299. const {session}=await channel(),abort=new AbortController()
  300. const execute=(runner as any).execute.bind(runner)
  301. let release!:()=>void,waiting=false
  302. const gate=new Promise<void>(resolve=>{release=resolve})
  303. vi.spyOn(runner as any,'execute').mockImplementation(async(command:any)=>{if(command.kind==='lease.create'){waiting=true;await gate}return execute(command)})
  304. const result=createWorkspaceToolLease({target,profile:'default',workId:'cancel-race',session:()=>({runtimeId:session.session_id,storedId:session.stored_session_id}),signal:abort.signal,
  305. assertActive:()=>{if(abort.signal.aborted)throw new Error('stopped')},catalog:()=>[],call:async()=>({}),onFailure:()=>{}}).catch(error=>error)
  306. await vi.waitFor(()=>expect(waiting).toBe(true));abort.abort()
  307. await vi.waitFor(()=>expect((runner as any).closedLeases.size).toBe(1));release()
  308. expect(await result).toBeInstanceOf(Error)
  309. expect((runner as any).leases.size).toBe(0)
  310. expect(bindings).toHaveLength(0)
  311. })
  312. it.each([0o600,0o644])('runs the CLI with private configuration and rejects broad permissions (%s)',async(mode)=>{
  313. controller.abort();await running
  314. const file=join(home,'runner.json');writeFileSync(file,JSON.stringify(config),{mode})
  315. const bundle=process.env.RUNNER_BUNDLE_PATH
  316. const args=bundle?[bundle,'--config',file]:['--import','tsx','src/runner/index.ts','--config',file]
  317. const child=spawn(process.execPath,args,{stdio:['ignore','ignore','pipe']})
  318. let output='';child.stderr?.on('data',data=>{output+=String(data)})
  319. const exited=once(child,'exit')
  320. try {
  321. if(mode===0o644){expect((await exited)[0]).not.toBe(0);expect(output).toContain('chmod 600');return}
  322. await vi.waitFor(()=>{if(child.exitCode!==null)throw new Error(`Runner 提前退出 ${child.exitCode}: ${output}`);expect(output).toContain('执行节点已连接')},{timeout:7000})
  323. expect((await target.session.request('/api/profiles')).status).toBe(200)
  324. child.kill('SIGTERM')
  325. expect((await exited)[0]).toBe(0)
  326. expect(output).toContain('执行节点已停止')
  327. expect(output).not.toContain(config.token)
  328. }finally{if(child.exitCode===null&&child.signalCode===null){child.kill('SIGTERM');await exited}}
  329. },15000)
  330. it('refuses a computer gateway on a legacy Runner before any native session is opened',async()=>{
  331. const target=hub.target('owner','local',{environmentId:randomUUID(),agentId:randomUUID(),ownerKey:'a'.repeat(64)})!
  332. const gateway=new WorkspaceGateway(target,{workId:randomUUID(),authorize:()=>{}});gateways.push(gateway)
  333. await expect(gateway.connect()).rejects.toMatchObject({code:'computer_unavailable'})
  334. expect(rpc.some(call=>call.method==='session.create')).toBe(false)
  335. })
  336. it('binds chunked artifacts to one live connection, validates bytes and publishes exactly once',async()=>{
  337. const {createHash}=await import('node:crypto'),bytes=Buffer.from('artifact payload'),id=randomUUID()
  338. const publish=vi.fn(async(name:string,data:Buffer)=>({id:randomUUID(),name,size:data.length}))
  339. const gateway=new WorkspaceGateway(target,{workId:randomUUID(),authorize:()=>{},publishArtifact:publish});gateways.push(gateway)
  340. await gateway.connect()
  341. const connectionId=[...(hub as any).connections.keys()][0]
  342. const send=(body:object)=>machine('artifact',{connectionId,id,...body})
  343. const metadata={phase:'begin',name:'report.txt',size:bytes.length,digest:createHash('sha256').update(bytes).digest('hex')}
  344. expect((await send(metadata)).status).toBe(200)
  345. expect((await send({phase:'finish'})).status).toBe(409)
  346. expect((await send({phase:'append',index:0,data:bytes.toString('base64')})).status).toBe(200)
  347. expect((await send({phase:'append',index:0,data:bytes.toString('base64')})).status).toBe(200)
  348. expect((await send({phase:'append',index:0,data:Buffer.from('wrong').toString('base64')})).status).toBe(409)
  349. const first=await (await send({phase:'finish'})).json()
  350. expect(await (await send({phase:'finish'})).json()).toEqual(first)
  351. expect(publish).toHaveBeenCalledExactlyOnceWith('report.txt',bytes)
  352. expect((await machine('artifact',{...metadata,connectionId:randomUUID(),id:randomUUID()})).status).toBe(403)
  353. auth.version++
  354. expect((await send({phase:'finish'})).status).toBe(403)
  355. })
  356. it('keeps only stop operations available on an existing channel after task permission is revoked',async()=>{
  357. let allowed=true
  358. const gateway=new WorkspaceGateway(target,{workId:randomUUID(),authorize:()=>{if(!allowed)throw new Error('revoked')}});gateways.push(gateway)
  359. await gateway.connect();const session=await gateway.rpc('session.create',{profile:'default'})
  360. allowed=false
  361. await expect(gateway.rpc('prompt.submit',{session_id:session.session_id,text:'forbidden'})).rejects.toMatchObject({code:'runner_command_not_admitted'})
  362. expect(await gateway.rpc('session.interrupt',{session_id:session.session_id})).toEqual({ok:true})
  363. expect(await gateway.rpc('session.active_list',{profile:'default',current_session_id:session.session_id})).toEqual({sessions:[{id:session.session_id,status:'idle'}]})
  364. await expect(gateway.rpc('session.active_list',{profile:'default',current_session_id:'unowned'})).rejects.toMatchObject({code:'runner_session_forbidden'})
  365. expect(rpc.filter(call=>call.method==='prompt.submit')).toHaveLength(0)
  366. })
  367. it('carries workspace memory policy through the Runner to the authenticated Hermes binding',async()=>{
  368. const {session}=await channel(),abort=new AbortController()
  369. const lease=await createWorkspaceToolLease({target,profile:'default',workId:'memory-work',workspaceMemory:true,
  370. session:()=>({runtimeId:session.session_id,storedId:session.stored_session_id}),signal:abort.signal,
  371. assertActive:()=>{},catalog:()=>[],call:async()=>({}),onFailure:()=>{}})
  372. try{await lease.bind();expect(bindings.at(-1)).toMatchObject({workspace_memory:true})}finally{await lease.dispose()}
  373. })
  374. it('distinguishes automatically supported browsers from explicit node opt-out, old runners and offline nodes',()=>{
  375. const agent=store.createAgent('owner',{name:'浏览器节点状态',profile:'default'}),record=hub.records()[0]!
  376. const states=(hub as any).online as Map<string,{features:string[]}>,state=states.get(record.id)!,features=state.features
  377. try{
  378. expect(state.features).toContain('managed-browser-setup-v1')
  379. expect(hub.browserRunner('owner',agent).id).toBe(record.id)
  380. auth.allowed=false
  381. expect(()=>hub.browserRunner('owner',agent)).toThrow('浏览器 Profile 未授权')
  382. auth.allowed=true
  383. state.features=['managed-browser-disabled-v1']
  384. expect(()=>hub.browserRunner('owner',agent)).toThrow('节点管理员已关闭托管浏览器')
  385. state.features=[]
  386. expect(()=>hub.browserRunner('owner',agent)).toThrow('执行节点版本尚不支持自动准备浏览器')
  387. states.delete(record.id)
  388. expect(()=>hub.browserRunner('owner',agent)).toThrow('执行节点暂未连接')
  389. store.put('_system','runner',record.id,{...record,enabled:false})
  390. expect(()=>hub.browserRunner('owner',agent)).toThrow('尚未找到此 Bot 的执行节点')
  391. }finally{auth.allowed=true;state.features=features;states.set(record.id,state);store.put('_system','runner',record.id,record)}
  392. })
  393. it('advertises only vault references and binds them to the current Runner incarnation and source permission',()=>{
  394. const agent={id:randomUUID(),nodeId:'local',profile:'default',archived:false} as any
  395. const state=(hub as any).online.get(config.runnerId)
  396. expect(state.features).toContain('credential-ref-v1');expect(state.features).not.toContain('credential-executor-v1')
  397. expect(hub.credentialBinding('owner',agent)).toEqual({runnerId:config.runnerId,runnerInstance:state.instance,runnerEpoch:state.epoch})
  398. auth.allowed=false;expect(()=>hub.credentialBinding('owner',agent)).toThrowError(expect.objectContaining({code:'vault_agent_forbidden'}));auth.allowed=true
  399. state.features=state.features.filter((f:string)=>f!=='credential-ref-v1')
  400. expect(()=>hub.credentialBinding('owner',agent)).toThrowError(expect.objectContaining({code:'vault_runner_upgrade_required'}))
  401. })