scanned 61 file(s), 5.38 MB of source, external domains: 127.0.0.1, api-staging.ara.so, api.ara.so, api.github.com, api.reasonmachines.ai, api.reasonmachines.com, auth.x.ai, camo.githubusercontent.com, cdn.playwright.dev, chromewebstore.google.com, claude.ai, cursor.com, docs.reasonmachines.com, dotenvx.com, dummy.test, edgeupdates.microsoft.com, example.com, ffmpeg.martin-riedl.de, github.com, github.com.helper, json-schema.org, mcp.reasonmachines.com, nodejs.org, openbox.org, playwright.bloburl, playwright.dev, playwright.download.prss.microsoft.com, proxy.example.com, raw.githubusercontent.com, reasonmachines.ai, reasonmachines.com, registry.npmjs.org, staging-api.reasonmachines.ai, staging-api.reasonmachines.com, staging.reasonmachines.ai, storage.googleapis.com, support.microsoft.com, worker-probe.invalid, www.apple.com, www.w3.org
47\r
L48: Connection blocked by network allowlist`);return}if(W||Y.destroyed){Y.destroy();return}let P=jJ(j)??j;if($.mitmCA&&($.shouldTerminateTLS?.(P,C)??!0)){Y.write(`HTTP/1.1 200 Connecti...
L49: \r
...
L55: \r
L56: `)}}),J.on("request",async(Q,Y)=>{Q.on("error",(G)=>{Z(`Client request error: ${G.message}`,{level:"error"})}),Y.on("error",(G)=>{Z(`Client response error: ${G.message}`,{level:"er...
L57: `)),$.end(eq(W))}function L7($){return Buffer.from([5,$,0,1,0,0,0,0,0,0])}function tq($){return new Promise((J)=>{let X=Buffer.alloc(0),Q=(W)=>{$.off("data",G),clearTimeout(Y),J(W)...
...
L60: mux backend dial failed (${H})
L61: `)}),M.on("error",()=>O.destroy()),M.once("close",()=>O.destroy()),O.once("close",()=>M.destroy()),M.pipe(O),O.pipe(M)}let U=$6((M)=>{G.add(M),M.once("close",()
HighCommand Output Exfiltration
Source combines command execution, command-output handling, and outbound requests; review data flow before blocking.
bin/runtime/srt/sandbox-runtime.mjsView on unpkg · L47 84`)}o.clear();for(let a of f)o.add(a)},NG);W0.unref();let H$=(f)=>{if(!X.readinessProbes)P5({config:$,readiness:f,signal:j.signal,idle:()=>x()===0,permissions:J.roots[0].permissions,onReady:(a)=>{O(a,[]).then(n)}})},M$=q?B.final.then(async(f)=>{if(j.signal.aborted)return;n(await O(f,[]));let a=U9.filter((q0)=>f[q0]===!0);process.stderr.write(`Reason worker: deferred lanes decided (${a.length?`ready: ${a.join(", ")}`:"none ready"}).
85`),H$(f)},()=>{}):Promise.resolve();if(!q)H$(M);_?.then(async(f)=>{T=f;for(;;){let a=F,q0=await O(a.worker.readiness??{},a.worker.probing??[]);if(j.signal.aborted)return;if(F!==a)continue;n(q0);return}});let j1=q&&F.worker.probing?.includes("pty.start")?B.pty.then(async(f)=>{let a=()=>F.worker.probing?.includes("pty.start")===!0;if(j.signal.aborted||!a())return;let q0=await O({...F.worker.readiness,"pty.start":f},(F.worker.probing??[]).filter((i)=>i!=="pty.start"));if(j.signal.aborted||!a())return;n(q0)},()=>{}):Promise.resolve(),P$=()=>({version:1,instanceId:Q,deviceId:J.deviceId,phase:E,drai ...
88`)}}):void 0),X0=(f)=>{if(f==="stop")T$();if(f==="reload_roots"){let a=t($);if(!a||a.deviceId!==J.deviceId)throw Error("worker_identity_changed");J.roots=a.roots;let q0=Q6(J.roots,uJ());if(q0)z.root_paths=q0;else delete z.root_paths;P?.check()}if(f==="drain"||f==="resume"){if(L||Date.parse(Y)<=Date.now())throw Error("worker_stopping_or_expired");G={...G,drained:f==="drain"},I0($,G)}return P$()};X.prestartedControl?.handle(X0);let x$=X.prestartedControl?await X.prestartedControl.closed:await x2($,Q,X0),Y$,S$=!1,h0=()=>{let f=Date.parse(Y)-Date.now();if(f>0){Y$=setTimeout(h0,Math.min(f,214748364 ...
89`)}}),S.arm(),setTimeout(oJ,0);else if(!m.handsPrespawn&&S)S.close(),S=null}if(m.type==="heartbeat"){if(P&&!L&&Date.now()>=V3)V3=Date.now()+q3,P.check().then((p0)=>{N3=p0?0:N3+1,V3=Date.now()+(p0?q3:Math.min(q3,z4*2**Math.min(N3-1,10)))});if(I=m.serverTime,C=m.drain,D1(),!L&&E$)v?.(m.latestCliVersions?.[E$]);if(!L)E="running";if(!L&&!h&&P$().executionEligible){if(h=!0,X.onStartup?.("ready"),(X.platform??process.platform)==="darwin")setTimeout(()=>{try{E9({skipWhenSettled:!0})}catch{}},0)}}if(m.type==="reconnecting"&&!L)E="reconnecting";if(m.type==="stopped")W=0;X.onEvent?.(m)})}),await P?.sett ...
90`)});else if(L&&!S$)await e9({state:J,client:f});if(a$)await nJ().catch(()=>{return})}catch(f){if(!(f instanceof T0&&f.status===401))throw f;if(I0($,{...G,revoked:!0}),f.code==="device_revoked")X.onDeviceRevoked?.();throw Error("worker_revoked")}finally{if(clearTimeout(Y$),clearInterval(W0),y)clearTimeout(y);if(W1)process.removeListener("SIGTERM",Q$),process.removeListener("SIGINT",T$);X.signal?.removeEventListener("abort",Q$),j.abort(),S?.close(),await P?.settled().catch(()=>{return}),await D?.broker.close().catch(()=>{return}),await x$()}}function pJ($=process.env){if($.REASON_RELAY_CUSTOM_D ...
91`;if(Buffer.byteLength(Z)>65536)throw Error("worker_ssh_frame_too_large");let Q;try{await new Promise((X,Y)=>{Q=this.clock.after(J,()=>Y(Error("worker_ssh_write_timeout"))),this.output.write(Z,(G)=>G?Y(Error("worker_ssh_connection_failed")):X())})}finally{Q?.()}}async receive($=30000,J){if(J?.aborted)throw Error("worker_ssh_cancelled");if(this.queue.length)return this.queue.shift();if(this.failure)throw this.failure;if(this.waiter)throw Error("worker_ssh_concurrent_read");let Z,Q;try{return await new Promise((X,Y)=>{this.waiter={resolve:X,reject:Y},Q=()=>{this.waiter=void 0,Y(Error("worker_ssh ...
102exec "$a" worker __ssh-bootstrap`;return`exec /usr/bin/env -i PATH=/usr/bin:/bin:/usr/sbin:/sbin /bin/sh -c ${k9(J)}`}function M6($,J){if(!/^[A-Za-z0-9][A-Za-z0-9_.-]{0,127}$/.test($.alias)||!y9($.sshConfig))throw Error("worker_ssh_invalid_target");return["-T","-a","-F",$.sshConfig,"-o","BatchMode=yes","-o","StrictHostKeyChecking=yes","-o","UpdateHostKeys=no","-o","ForwardAgent=no","-o","ClearAllForwardings=yes","-o","PermitLocalCommand=no","-o","GSSAPIDelegateCredentials=no","-o","SessionType=default","-o","StdinNull=no","-o","ForkAfterAuthentication=no","-o","ControlMaster=no","-o","ControlP ...
104`)}if(j.type==="stopped"){if(!M)throw Error("worker_ssh_invalid_readiness");return 0}}}catch(q){if(K.signal.aborted){H?.();try{await V.send({type:"stop"});let M=Y.now()+Z.shutdownGraceMs+1e4;while(Y.now()<M)if(q6.parse(n2(await V.receive(Math.max(1,M-Y.now())))).type==="stopped")return 0}catch{}throw Error("worker_ssh_stop_unconfirmed")}if(q instanceof Error&&q.message==="worker_ssh_connection_closed"){let M=B??await Promise.race([G.result,new Promise((T)=>setTimeout(T,100))]);if(M?.exitCode)throw Error(M.errorCode)}throw q}finally{H?.(),process.removeListener("SIGINT",N),process.removeListene ...
106`),await Z}finally{clearTimeout(Q),Y.stop(!0),process.stdin.removeListener("end",X),process.stdin.pause()}}import{closeSync as oG,createReadStream as eG,fstatSync as $K,readFileSync as JK}from"fs";var I6="/run/sc/instance-generation";var rG=/^[1-9][0-9]{0,15}\n?$/;function tG($){return typeof $==="number"&&Number.isSafeInteger($)&&$>0}function C6($){if(typeof $!=="string"||!rG.test($))return null;let J=Number($.trim());return tG(J)?J:null}var P6=3,ZK=600000,QK=65536,XK=500;function E6($){if($.length!==3||$[0]!=="standby"||$[1]!=="--handoff-fd"||$[2]!==String(P6))throw Error("worker_standby_inv ...
3`)}var Pr=(n)=>(i,o,v,r)=>{let t=v?{...v,async:!1}:{async:!1},e=i._zod.run({value:o,issues:[]},t);if(e instanceof Promise)throw new C;if(e.issues.length){let u=new(r?.Err??n)(e.issues.map((g)=>Y(g,t,W())));throw Qn(u,r?.callee),u}return e.value},Fn=Pr(B),Jr=(n)=>async(i,o,v,r)=>{let t=v?{...v,async:!0}:{async:!0},e=i._zod.run({value:o,issues:[]},t);if(e instanceof Promise)e=await e;if(e.issues.length){let u=new(r?.Err??n)(e.issues.map((g)=>Y(g,t,W())));throw Qn(u,r?.callee),u}return e.value},Tn=Jr(B),Lr=(n)=>(i,o,v)=>{let r=v?{...v,async:!1}:{async:!1},t=i._zod.run({value:o,issues:[]},r);if(t ...
HighEval
Package source references dynamic code evaluation.
bin/vm-hands/vm-hands-entry-lite-samn6qm5.jsView on unpkg · L1 5`))}}var jo={major:4,minor:4,patch:3};var z=l("$ZodType",(n,i)=>{var o;n??(n={}),n._zod.def=i,n._zod.bag=n._zod.bag||{},n._zod.version=jo;let v=[...n._zod.def.checks??[]];if(n._zod.traits.has("$ZodCheck"))v.unshift(n);for(let r of v)for(let t of r._zod.onattach)t(n);if(v.length===0)(o=n._zod).deferred??(o.deferred=[]),n._zod.deferred?.push(()=>{n._zod.run=n._zod.parse});else{let r=(e,u,g)=>{let $=er(e),c;for(let b of u){if(b._zod.def.when){if(Jt(e))continue;if(!b._zod.def.when(e))continue}else if($)continue;let S=e.issues.length,D=b._zod.check(e);if(D instanceof Promise&&g?.async===!1)throw ne ...