Lines 13-53javascript
13 subscription TeleportRequestedWatch($devSessionId: String!) {
14 teleportRequested(devSessionId: $devSessionId) {
23 query TeleportRunRepro($id: String!) {
30 mutation ReportTeleportResult($devSessionId: String!, $runId: String!, $status: String!) {
31 reportTeleportResult(devSessionId: $devSessionId, runId: $runId, status: $status)
33`);function ze({cwd:e,devSessionId:r,onSubscriptionDead:o,sseClient:n}){let t=new Set,i=n.subscribe({query:Fr(Nr),variables:{devSessionId:r}},{complete:()=>{},error:a=>{let l=a instanceof Error?a.message:String(a);s.warn("teleportRequested SSE failed: %s; re-registering session",l),o(l)},next:a=>{jr({cwd:e,devSessionId:r,event:a.data?.teleportRequested,running:t})}});return()=>{t.forEach(a=>{a.abort()}),t.clear(),i()}}function jr({cwd:e,devSessionId:r,event:o,running:n}){if(o==null)return;let t=new AbortController;n.add(t),zr({cwd:e,devSessionId:r,event:o,signal:t.signal}).catch(i=>{s.error({e ...
34`);let l=await Fe({cwd:e,onReady:()=>{t("opened")},signal:n,step:o.stepIndex+1,target:i});l.kind==="done"&&l.result.kind==="handed-over"||(s.warn({kind:l.kind,runId:o.runId},"teleport could not open"),await t(l.kind==="unplannable"?"unplannable":"error"))}async function Jr({cwd
35 query DaemonExploration($devSessionId: String!) {
HighChild Process
Package source references child process execution.
dist/daemon-SGPPQESA.jsView on unpkg · L33 36 exploration(devSessionId: $devSessionId) {
43 subscription WatchExplorationChanged($devSessionId: String!) {
44 explorationChanged(devSessionId: $devSessionId) {
52`);function Sr({config:e,devSessionId:r,machinery:o,sseClient:n}){return $o({config:e,devSessionId:r,machinery:o}),n.subscribe({query:$(No),variables:{devSessionId:r}},{complete:()=>{},error:t=>{s.error(t,"exploration subscription error")},next:t=>{kr(o,t.data?.explorationChanged.exploration)}})}async function $o({config:e,devSessionId:r,machinery:o}){let n=await S({config:e,document:Fo,variables:{devSessionId:r}});kr(o,n.exploration)}function kr(e,r){r!=null&&(e.setMaxTrailLength(r.maxTrailLength),e.setConcurrency(r.localWorkers),e.setEnabled(r.active))}function vr({config:e,devSessionId:r,ma ...
53 subscription HooksPausedWatch($projectId: String!) {
Long lines were clipped for display.