diff --git a/.github/releases/v0.4.0.md b/.github/releases/v0.4.0.md
index 77fd880..a1834b4 100644
--- a/.github/releases/v0.4.0.md
+++ b/.github/releases/v0.4.0.md
@@ -15,7 +15,7 @@
 - Failed initial state publication closes the desktop connection so a fresh connection can retry. Late readiness completion cannot resurrect a closed connection.
 - Failed or ended session-event subscriptions reconnect with cancellable backoff, capped at five seconds.
 - Cleanup after session deletion or movement remains retryable and does not block another session's cleanup.
-- Shutdown intent survives failed cleanup. Physical-device aliases cannot bypass ownership or cause rollback to shut down another session's device.
+- Shutdown intent survives failed cleanup when the retry omits the flag. Explicit `shutdown: false` releases the attachment without another power-off attempt. Physical-device aliases cannot bypass ownership or cause rollback to shut down another session's device.
 - Disposal cancels pending discovery and recovery. Destroyed viewers cannot reconnect or retain decode timers.
 
 Overlapping old tests were consolidated into transition tables, and the previous all-in-one desktop test was split into focused cases. Production function complexity is limited to nine. No runtime dependency or FSM framework was added.
@@ -33,6 +33,6 @@ Update the plugin pin in your global OpenCode configuration, preserving other se
 
 Plugin exports and tool names are unchanged. Android still requires SDK Platform-Tools, Emulator, and a configured AVD. iOS requires Xcode and an iOS Simulator runtime on macOS. Both require Node 22.19+ on the 22.x line, or Node 24+, with npm.
 
-Validation includes lint, formatting, typechecking, 296 passing tests and one existing Bun-only skip, rebuilt bundles, and installed-package loading. Each implementation PR passed Linux CI before merging; lifecycle suites also passed three consecutive local runs. Two fresh helper installations, native module loading, offline reuse, and stale-cache rejection passed on macOS arm64.
+Validation includes lint, formatting, typechecking, 297 passing tests and one existing Bun-only skip, rebuilt bundles, and installed-package loading. Each implementation PR passed Linux CI before merging; lifecycle suites also passed three consecutive local runs. Two fresh helper installations, native module loading, offline reuse, and stale-cache rejection passed on macOS arm64.
 
 Full changelog: https://github.com/viralcodex/opencode-demul/compare/v0.3.0...v0.4.0
diff --git a/dist/gui.cjs b/dist/gui.cjs
index ee98c84..39df4a9 100644
--- a/dist/gui.cjs
+++ b/dist/gui.cjs
@@ -1,4 +1,4 @@
-"use strict";Object.defineProperties(exports,{__esModule:{value:!0},[Symbol.toStringTag]:{value:"Module"}});const Y=require("solid-js/web"),ne=require("solid-js"),Ot=require("@opencode/plugin/gui"),pa=require("@opencode/schema/rpc"),p=require("effect"),ma=8*1024*1024,qe=p.Schema.optional,we=p.Schema.String.check(p.Schema.isMaxLength(2048)),si=p.Schema.String.check(p.Schema.isMaxLength(1e5)),At=p.Schema.Int.check(p.Schema.isGreaterThanOrEqualTo(0)),ai=p.Schema.Int.check(p.Schema.isBetween({minimum:0,maximum:1e6})),je=p.Schema.Literals(["ios","android"]).annotate({identifier:"Device.Platform"}),ga=p.Schema.Literals(["shutdown","booting","booted","unavailable"]).annotate({identifier:"Device.DeviceState"}),Sa=p.Schema.Literals(["available","owned-by-this-host","owned-by-other","unknown"]).annotate({identifier:"Device.Ownership"}),ci=p.Schema.Literals(["apps","launch","install","snapshot","press","fill","swipe","key","screenshot","stream"]).annotate({identifier:"Device.Capability"}),ya=p.Schema.Literals(["home","back","recents","lock","volumeUp","volumeDown"]).annotate({identifier:"Device.NavigationKey"}),Nn=At.annotate({identifier:"Device.Generation"}),Mn=p.Schema.String.check(p.Schema.isPattern(/^dh_[a-f0-9-]{36}$/u)).pipe(p.Schema.brand("Device.HandleToken")).annotate({identifier:"Device.HandleToken"}),Ie=p.Schema.Struct({token:Mn,platform:je,deviceId:we,generation:Nn}).annotate({identifier:"Device.DeviceHandle"}),gi=p.Schema.String.check(p.Schema.isPattern(/^@?e[1-9][0-9]*$/u)).pipe(p.Schema.brand("Device.ElementRef")).annotate({identifier:"Device.ElementRef"}),li=p.Schema.Struct({token:Mn,generation:Nn,revision:At,ref:gi}).annotate({identifier:"Device.SnapshotReference"}),va=p.Schema.Struct({ref:qe(gi),role:we,name:qe(si),value:qe(si),enabled:qe(p.Schema.Boolean),focused:qe(p.Schema.Boolean)}).annotate({identifier:"Device.AccessibilityNode"}),wa=p.Schema.Struct({token:Mn,generation:Nn,revision:At,interactiveOnly:p.Schema.Boolean,complete:p.Schema.Boolean,nodes:p.Schema.Array(va)}).annotate({identifier:"Device.Snapshot"}),An=p.Schema.Struct({x:ai,y:ai}).annotate({identifier:"Device.LogicalPoint"}),ba=p.Schema.Struct({id:we,name:we,platform:je,osVersion:qe(we),state:ga,ownership:Sa}).annotate({identifier:"Device.DeviceInfo"}),_a=p.Schema.Struct({supported:p.Schema.Array(ci),unsupported:p.Schema.Array(p.Schema.Struct({capability:ci,reason:we}))}).annotate({identifier:"Device.Capabilities"}),ka=p.Schema.Struct({id:we,name:qe(we)}).annotate({identifier:"Device.AppInfo"}),xa=p.Schema.Struct({app:we,state:p.Schema.Literals(["launched","foreground","unknown"])}).annotate({identifier:"Device.LaunchResult"}),Ea=p.Schema.Struct({installed:p.Schema.Boolean,app:qe(we)}).annotate({identifier:"Device.InstallResult"}),Ia=p.Schema.Struct({data:p.Schema.Uint8ArrayFromBase64.check(p.Schema.isMaxLength(ma)),width:At,height:At,deviceId:we,platform:je}).annotate({identifier:"Device.Screenshot"}),Da=p.Schema.Literal("h264").annotate({identifier:"Device.StreamProtocol"}),La=p.Schema.Struct({platform:je,deviceId:we,baseUrl:we,token:we,protocol:Da,loopback:p.Schema.Literal(!0)}).annotate({identifier:"Device.StreamDescriptor"}),Ta=p.Schema.Literals(["missing-prerequisite","permission-denied","device-busy","detached","stale-reference","unsupported","not-found","invalid-artifact","timeout","helper-failed","internal"]).annotate({identifier:"Device.DeviceErrorCode"}),Rn=p.Schema.Struct({code:Ta,message:we,mayHaveExecuted:p.Schema.Boolean}).annotate({identifier:"Device.DeviceError"}),ct=p.Schema.optional,Ue=p.Schema.String.check(p.Schema.isMaxLength(2048)),Si=Ue.check(p.Schema.isMinLength(1)),Bn={sessionID:Si,connectionID:p.Schema.String},di={...Bn,requestID:p.Schema.String},hi=p.Schema.Number.check(p.Schema.isInt(),p.Schema.isBetween({minimum:1,maximum:1e6})),ui=p.Schema.optional(p.Schema.Struct({width:hi,height:hi})),lt=p.Schema.Struct({sessionID:Si,serverID:Ue,location:p.Schema.optionalKey(p.Schema.Struct({directory:Ue}))}),Yt=p.Schema.Struct({handle:Ie,selection:p.Schema.optionalKey(p.Schema.Struct({platform:je,deviceId:Ue})),capabilities:_a,agentAccess:p.Schema.Boolean}).annotate({identifier:"DeviceBridge.Attachment"}),yi=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("list"),platform:ct(je)}),p.Schema.Struct({type:p.Schema.Literal("state")}),p.Schema.Struct({type:p.Schema.Literal("open"),platform:je,deviceId:Ue,boot:ct(p.Schema.Boolean)}),p.Schema.Struct({type:p.Schema.Literal("apps"),handle:Ie}),p.Schema.Struct({type:p.Schema.Literal("launch"),handle:Ie,app:Ue,deepLink:ct(Ue),relaunch:ct(p.Schema.Boolean)}),p.Schema.Struct({type:p.Schema.Literal("install"),handle:Ie,artifactPath:Ue}),p.Schema.Struct({type:p.Schema.Literal("snapshot"),handle:Ie,interactiveOnly:ct(p.Schema.Boolean)}),p.Schema.Struct({type:p.Schema.Literal("press"),handle:Ie,reference:li}),p.Schema.Struct({type:p.Schema.Literal("tap"),handle:Ie,point:An,viewport:ui}),p.Schema.Struct({type:p.Schema.Literal("fill"),handle:Ie,reference:li,text:Ue}),p.Schema.Struct({type:p.Schema.Literal("swipe"),handle:Ie,from:An,to:An,viewport:ui}),p.Schema.Struct({type:p.Schema.Literal("key"),handle:Ie,key:ya}),p.Schema.Struct({type:p.Schema.Literal("screenshot"),handle:Ie}),p.Schema.Struct({type:p.Schema.Literal("close"),handle:Ie,shutdown:ct(p.Schema.Boolean)})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Operation"}),Oa=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("devices"),devices:p.Schema.Array(ba)}),p.Schema.Struct({type:p.Schema.Literal("state"),state:p.Schema.NullOr(Yt)}),p.Schema.Struct({type:p.Schema.Literal("attachment"),attachment:Yt}),p.Schema.Struct({type:p.Schema.Literal("apps"),apps:p.Schema.Array(ka)}),p.Schema.Struct({type:p.Schema.Literal("launch"),result:xa}),p.Schema.Struct({type:p.Schema.Literal("install"),result:Ea}),p.Schema.Struct({type:p.Schema.Literal("snapshot"),snapshot:wa}),p.Schema.Struct({type:p.Schema.Literal("screenshot"),screenshot:Ia}),p.Schema.Struct({type:p.Schema.Literal("done")})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Value"}),Xt=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("success"),value:Oa}),p.Schema.Struct({type:p.Schema.Literal("failure"),error:Rn})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Outcome"}),Aa=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("success"),stream:La}),p.Schema.Struct({type:p.Schema.Literal("failure"),error:Rn})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.StreamOutcome"}),Ca=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("attached"),connectionID:p.Schema.String,version:p.Schema.Literal(1)}),p.Schema.Struct({type:p.Schema.Literal("command"),connectionID:p.Schema.String,requestID:p.Schema.String}),p.Schema.Struct({type:p.Schema.Literal("cancel"),connectionID:p.Schema.String,requestID:p.Schema.String})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Control"}),Me=p.Schema.toStandardSchemaV1,Jt={unavailable:Me(Rn)};pa.Rpc.define({id:"device.control",methods:{attach:{input:Me(p.Schema.Struct({...Bn,version:p.Schema.Literal(1)})),output:Me(p.Schema.Literals(["closed","replaced"])),errors:Jt},state:{input:Me(p.Schema.Struct({...Bn,state:p.Schema.NullOr(Yt)})),output:Me(p.Schema.Void),errors:Jt},command:{input:Me(p.Schema.Struct(di)),output:Me(yi),errors:Jt},result:{input:Me(p.Schema.Struct({...di,outcome:Xt})),output:Me(p.Schema.Void),errors:Jt}},events:{control:{schema:Me(Ca)}}});const fi=p.Schema.String.check(p.Schema.isMaxLength(2048)),Ba=Ot.Ipc.define({id:"demul.device.bridge.v2",state:p.Schema.Array(p.Schema.Struct({scope:lt,state:p.Schema.NullOr(Yt)})),methods:{connect:{input:lt},disconnect:{input:lt},list:{input:p.Schema.Struct({platform:p.Schema.optional(je),serverID:fi,sessionID:p.Schema.optionalKey(fi)}),output:Xt},access:{input:p.Schema.Struct({scope:lt,enabled:p.Schema.Boolean}),output:Xt},manual:{input:p.Schema.Struct({scope:lt,operation:yi}),output:Xt},stream:{input:p.Schema.Struct({scope:lt,handle:Ie}),output:Aa}}});function pi(S){let I;return{async run(T,B){I?.abort();const q=new AbortController;I=q,S.pending(!0);try{const o=await T(q.signal);I===q&&B(o)}catch(o){I===q&&!q.signal.aborted&&S.error(o)}finally{I===q&&(I=void 0,S.pending(!1))}},cancel(){I?.abort(),I=void 0,S.pending(!1)}}}const Pa=1397050709,Na={1:16,2:24},mi=new Uint8Array([0,0,0,1]);function Ma(S){const I=S instanceof Uint8Array?S:new Uint8Array(S);if(I.byteLength<4)return;const T=new DataView(I.buffer,I.byteOffset,I.byteLength);return T.getUint32(0)===Pa?Ra(I,T):vi(I,performance.now()*1e3,!1)}function Ra(S,I){if(S.byteLength<16)return;const T=Na[I.getUint8(4)];if(!T||S.byteLength<=T)return;const B=I.getBigUint64(8);if(!(B>BigInt(Number.MAX_SAFE_INTEGER)))return vi(S.subarray(T),Number(B),(I.getUint8(5)&1)===1,T===24?Number(I.getBigUint64(16))/1e3:void 0)}function vi(S,I,T,B){const q=Pn(S,0);if(q===void 0||q>=S.byteLength)return;const o=Ua(S);return{bytes:S,...o,key:o.key||o.picture&&T,timestamp:I,serverTimestamp:B}}function Ua(S){let I=!1,T=!1,B,q;for(const o of ja(S)){const le=o[0]&31;le===5&&(I=!0),le>=1&&le<=5&&(T=!0),le===7&&(B=o),le===8&&(q=o)}return{key:I,picture:T,codec:B&&$a(B),sps:B,pps:q}}function*ja(S){let I=Pn(S,0);if(I!==void 0){for(let T=I;T<S.byteLength-2;T++){const B=Pn(S,T);B!==void 0&&(T>I&&(yield S.subarray(I,T)),I=B,T=B-1)}I<S.byteLength&&(yield S.subarray(I))}}function Pn(S,I){if(!(S[I]!==0||S[I+1]!==0)){if(S[I+2]===1)return I+3;if(S[I+2]===0&&S[I+3]===1)return I+4}}function $a(S){if(!(S.byteLength<4))return`avc1.${[S[1],S[2],S[3]].map(I=>I.toString(16).padStart(2,"0")).join("")}`}class Fa{codec;sps;pps;update(I){I.sps&&(this.sps=I.sps.slice(),this.codec=I.codec),I.pps&&(this.pps=I.pps.slice())}bytes(I){if(!I.key)return I.bytes;const T=[];if(!I.sps&&this.sps&&T.push(mi,this.sps),!I.pps&&this.pps&&T.push(mi,this.pps),!T.length)return I.bytes;T.push(I.bytes);const B=new Uint8Array(T.reduce((o,le)=>o+le.byteLength,0));let q=0;for(const o of T)B.set(o,q),q+=o.byteLength;return B}clear(){this.codec=void 0,this.sps=void 0,this.pps=void 0}}async function Wa(S,I){const T=await VideoDecoder.isConfigSupported(S);if(!I.current())return;if(!T.supported)throw new Error(`H.264 codec ${S.codec} is not supported by this browser`);const B=new VideoDecoder({output(q){try{I.current()&&I.output(q)}catch(o){I.error(`Device video draw failed: ${o instanceof Error?o.message:String(o)}`)}finally{q.close()}},error(q){I.current()&&I.error(`H.264 decoder failed: ${q.message}`)}});try{B.configure(T.config??S)}catch(q){throw B.close(),new Error(`H.264 decoder configuration failed: ${q instanceof Error?q.message:String(q)}`)}return B}function Ha(S,I,T,B){if(!(!S||S!==I||T!=="playing"||!Zt(B)))return{token:S,width:B.width,height:B.height}}function Va(S,I){return!!I&&S.token===I.token&&S.width===I.width&&S.height===I.height}function za(S){let I=!1,T={type:"idle"};const B=()=>{try{return Ga(S)}catch(o){return S.onState("paused"),S.onError(o instanceof Error?o.message:String(o)),()=>{}}},q=()=>{if(T.type==="destroyed")return;const o=I&&document.visibilityState==="visible";if(o&&T.type==="idle"){T={type:"running",stop:B()};return}o||T.type!=="running"||(T.stop(),T={type:"idle"},S.onState(I?"paused":"idle"))};return document.addEventListener("visibilitychange",q),{active(o){T.type!=="destroyed"&&(I=o,q())},destroy(){if(T.type==="destroyed")return;const o=T;T={type:"destroyed"},document.removeEventListener("visibilitychange",q),o.type==="running"&&o.stop(),S.canvas.width=0,S.canvas.height=0,S.onState("idle")}}}function qa(S,I,T){if(![S.left,S.top,S.width,S.height,I.width,I.height,T.x,T.y].every(Number.isFinite)||S.width<=0||S.height<=0||!Zt(I))return;const B=Math.min(S.width/I.width,S.height/I.height),q=I.width*B,o=I.height*B,le=T.x-S.left-(S.width-q)/2,ee=T.y-S.top-(S.height-o)/2;if(!(le<0||ee<0||le>=q||ee>=o))return{x:Math.min(I.width-1,Math.floor(le/B)),y:Math.min(I.height-1,Math.floor(ee/B))}}function Ga(S){if(typeof VideoDecoder!="function"||typeof EncodedVideoChunk!="function")return S.onState("paused"),S.onError("H.264 device video requires WebCodecs support in this browser"),()=>{};const I=new URL("/video?frame-meta=1",new URL(S.stream.baseUrl).origin);I.protocol=I.protocol==="https:"?"wss:":"ws:";const T=new WebSocket(I,`opencode-device.${S.stream.token}`);let B={type:"waiting"};const q=new Fa;let o,le;const ee=()=>{clearTimeout(o),o=setTimeout(()=>fe("Device video did not produce a screen within 15 seconds. Refresh devices to retry."),15e3)};T.binaryType="arraybuffer",S.onState("connecting");const Z=()=>{if(T.readyState===WebSocket.OPEN)try{T.send(JSON.stringify({type:"reset-video",ack:!1}))}catch{}},de=(te=!1)=>{clearTimeout(le),le=void 0;const ae=B;B={type:"waiting"},"decoder"in ae&&ae.decoder.state!=="closed"&&ae.decoder.close(),te&&ae.type==="playing"&&(ee(),S.onState("connecting")),te&&Z()},G=()=>{B.type!=="stopped"&&(de(),B={type:"stopped"},clearTimeout(o),T.close())},fe=te=>{B.type!=="stopped"&&(G(),S.onError(te.replaceAll(S.stream.token,"[redacted]").slice(0,512)),S.onState("paused"))},be=(te,ae)=>{if(!(!("decoder"in B)||B.decoder!==ae||ae.state!=="configured")){B.waitingKeyframe=!1;try{le??=setTimeout(()=>{le=void 0,de(!0)},15e3),ae.decode(new EncodedVideoChunk({type:te.key?"key":"delta",timestamp:te.timestamp,data:q.bytes(te)}))}catch(he){fe(`H.264 decode failed: ${he instanceof Error?he.message:String(he)}`)}}},Ge=(te,ae)=>{de();const he={type:"configuring",codec:ae,missed:!1};B=he;const Ee=()=>B===he||"decoder"in B&&B.setup===he;Wa({codec:ae,optimizeForLatency:!0,hardwareAcceleration:"prefer-hardware"},{current:Ee,output(me){if(!("decoder"in B))return;const $e=B;clearTimeout(le),le=void 0,Ka(S,me,me.displayWidth,me.displayHeight),!(B!==$e||$e.type==="playing")&&(B={...$e,type:"playing"},clearTimeout(o),S.onState("playing"))},error:fe}).then(me=>{if(me){if(B!==he){me.close();return}B={type:"decoding",setup:he,decoder:me,waitingKeyframe:!0},be(te,me),Ee()&&"decoder"in B&&he.missed&&(B.waitingKeyframe=!0,Z())}}).catch(me=>{Ee()&&fe(`H.264 decoder setup failed: ${me instanceof Error?me.message:String(me)}`)})},De=()=>B.type==="configuring"?B.codec:"decoder"in B?B.setup.codec:void 0,Ke=te=>{q.update(te);const ae=De();ae&&q.codec!==ae&&de(!0)},Oe=te=>{const ae=q.codec??De();if(!ae)return Z();if("decoder"in B)return be(te,B.decoder);if(!te.key)return de(!0);Ge(te,ae)},Re=te=>{if(Ke(te),!!te.picture){if(B.type==="configuring"){B.missed=!0;return}if("decoder"in B&&B.decoder.decodeQueueSize>2)return de(!0);!te.key&&(!("decoder"in B)||B.waitingKeyframe)||Oe(te)}};return ee(),T.addEventListener("open",Z),T.addEventListener("message",te=>{if(B.type==="stopped")return;if(typeof te.data=="string"){const he=Ja(te.data);he?.type==="error"&&fe(`Device video failed: ${he.message}`),he?.type==="reset"&&(q.clear(),de(!0));return}if(!(te.data instanceof ArrayBuffer))return;const ae=Ma(te.data);ae&&Re(ae)}),T.addEventListener("error",()=>fe("Device video connection failed")),T.addEventListener("close",te=>{fe(`Device video connection closed (code ${te.code}). Refresh devices to retry.`)}),G}function Ka(S,I,T,B){if(!Zt({width:T,height:B}))throw new Error("Device video produced invalid screen dimensions");(S.canvas.width!==T||S.canvas.height!==B)&&(S.canvas.width=T,S.canvas.height=B);const q=S.canvas.getContext("2d",{alpha:!1});if(!q)throw new Error("Device video canvas is unavailable");q.drawImage(I,0,0,T,B)}function Ja(S){try{const I=JSON.parse(S);if(!I||typeof I!="object")return;if("ok"in I&&I.ok===!1)return{type:"error",message:"error"in I&&typeof I.error=="string"?I.error:"the capture session failed"};if(Xa(I))return{type:"reset"}}catch{return}}function Xa(S){return"type"in S&&S.type==="video-session"&&"size"in S&&S.size!==null&&typeof S.size=="object"&&Zt(S.size)}function Zt(S){return!("width"in S)||!("height"in S)?!1:typeof S.width=="number"&&typeof S.height=="number"&&Number.isSafeInteger(S.width)&&Number.isSafeInteger(S.height)&&S.width>0&&S.height>0}const Ya=".device-panel{box-sizing:border-box;display:flex;flex-direction:column;min-width:0;min-height:0;height:100%;color:var(--text-base);background:var(--background-base);overflow:hidden}.device-panel__picker{box-sizing:border-box;display:flex;align-items:center;justify-content:center;flex:none;gap:8px;width:100%;padding:12px}.device-panel__platforms{box-sizing:border-box;display:flex;flex:none;height:28px;border:1px solid var(--border-weak-base);border-radius:4px}.device-panel__platform,.device-panel__action{color:var(--text-base);background:transparent;cursor:pointer}.device-panel__platform:disabled,.device-panel__action:disabled{opacity:.5;cursor:default}.device-panel__platform{padding:0 8px;border:0;border-radius:3px;font:inherit;font-size:12px}.device-panel__platform[aria-pressed=true],.device-panel__platform:hover:not(:disabled){color:var(--text-strong);background:var(--background-stronger)}.device-panel__action{box-sizing:border-box;display:grid;place-items:center;flex:none;width:28px;height:28px;padding:0;border:1px solid var(--border-weak-base);border-radius:4px}.device-panel__action:hover:not(:disabled){background:var(--background-stronger)}.device-panel__device-select{flex:0 1 260px;width:260px}.device-panel select{box-sizing:border-box;min-width:0;height:28px;padding:0 24px 0 8px;color:var(--text-strong);background:var(--background-stronger);border:1px solid var(--border-weak-base);border-radius:4px;font:inherit;font-size:12px;text-overflow:ellipsis}.device-panel select:focus-visible,.device-panel__platform:focus-visible,.device-panel__action:focus-visible,.device-panel canvas:focus-visible{outline:2px solid var(--border-interactive-base);outline-offset:2px}.device-panel__error{position:absolute;inset:auto 12px 12px;display:flex;align-items:flex-start;gap:6px;padding:8px;color:var(--text-on-critical-weak);background:var(--surface-critical-weak);border-radius:4px;font-size:12px;overflow-wrap:anywhere}.device-panel__viewer{position:relative;display:grid;place-items:center;flex:1;min-width:0;min-height:0;overflow:hidden}.device-panel__viewer canvas{position:absolute;inset:0;display:block;width:100%;height:100%;object-fit:contain;touch-action:none;cursor:pointer}.device-panel__viewer-state{box-sizing:border-box;position:absolute;inset:0;display:flex;align-items:center;justify-content:center;gap:8px;padding:16px;color:var(--text-weak);background:color-mix(in srgb,var(--background-base) 88%,transparent);font-size:12px;text-align:center;overflow-wrap:anywhere;pointer-events:none}.device-panel__viewer-state--pending{inset:12px auto auto;padding:8px 12px;border-radius:4px;background:var(--background-base)}";var Za=Y.template('<button type=button class=device-panel__action aria-label="Refresh devices">'),Qa=Y.template('<footer class=device-panel__picker aria-label="Device selection"><div class=device-panel__platforms role=group aria-label="Device platform"></div><select class=device-panel__device-select aria-label=Device><option value disabled>'),ec=Y.template("<button type=button class=device-panel__platform>"),tc=Y.template("<option>"),nc=Y.template("<div class=device-panel__viewer-state role=status aria-live=polite aria-atomic=true>"),rc=Y.template("<div class=device-panel__error role=alert><span>"),ic=Y.template('<section class=device-panel aria-label="Device controls"><div class=device-panel__viewer><canvas aria-label="Live device screen"tabindex=0>');const Lt="device",Cn=S=>S.find(I=>I.ownership!=="owned-by-other"&&I.state==="booted")??S.find(I=>I.ownership!=="owned-by-other"&&I.state!=="unavailable"),oc=S=>S.platform==="ios"&&S.osVersion?`${S.name} (iOS ${S.osVersion})`:S.name,sc=Ot.Plugin.define({setup(S){const I=document.createElement("style");I.textContent=Ya,document.head.appendChild(I),ne.onCleanup(()=>I.remove());const T=S.main(Ba),B=new Map,q=ee=>JSON.stringify([ee.serverID,ee.sessionID]),o=ee=>{const Z=q(ee),de=B.get(Z);if(de)return de.ready;const G=new AbortController,fe=T.connect(ee,{signal:G.signal}).then(()=>{const be=B.get(Z);be?.abort===G&&(be.connected=!0)}).catch(be=>{throw B.get(Z)?.abort===G&&B.delete(Z),be});return B.set(Z,{scope:ee,abort:G,ready:fe,connected:!1}),fe};ne.createEffect(()=>{const ee=[...S.sessions.list(),S.sessions.current()];B.forEach((Z,de)=>{ee.some(G=>G?.id===Z.scope.sessionID&&G.server.id===Z.scope.serverID)||(B.delete(de),Z.abort.abort(),T.disconnect(Z.scope).catch(()=>{}))})}),ne.onCleanup(()=>{B.forEach(ee=>{ee.abort.abort(),T.disconnect(ee.scope).catch(()=>{})}),B.clear()});const le=ee=>{const Z=Ot.usePanel(),[de,G]=ne.createSignal([]),[fe,be]=ne.createSignal(""),[Ge,De]=ne.createSignal("android");let Ke=!1;const Oe=ne.createMemo(()=>de().filter(j=>j.platform===Ge())),[Re,te]=ne.createSignal(!1),[ae,he]=ne.createSignal(!1),[Ee,Ae]=ne.createSignal(),[me,$e]=ne.createSignal(),[dt,Fe]=ne.createSignal("idle"),[Ct,Bt]=ne.createSignal(),[ht,Ce]=ne.createSignal(),[ue,Pt]=ne.createSignal(),[Je,Nt]=ne.createSignal(0),pe=()=>({sessionID:ee.sessionID,serverID:ee.serverID,location:ee.location}),Le=()=>T.state()?.find(j=>q(j.scope)===q(pe()))?.state??void 0,Qe=ne.createMemo(()=>Le()?.handle.token);ne.createEffect(()=>{if(Qe(),ne.untrack(Re))return;const j=ne.untrack(Le);j&&(De(j.handle.platform),be(j.selection?.deviceId??j.handle.deviceId))});const ut=()=>de().find(j=>j.id===fe())?.state==="shutdown"?"Booting up device...":"Connecting to device...",ft=ne.createMemo(()=>{if(me()||Ee())return;if(Re())return ut();const j=Le();if(!j)return ae()?"Finding devices...":de().length===0?"No emulators or simulators found.":void 0;if(j.capabilities.supported.includes("stream")&&["idle","connecting"].includes(dt()))return"Almost done, preparing the screen..."});let Pe;const We=()=>{const j=ue();if(j)return Ha(Qe(),Ct(),dt(),j)};ne.createEffect(()=>{const j=q(pe()),Q=T.state()?.some(J=>q(J.scope)===j),K=B.get(j),X=K?.connected&&!Q;X&&(B.delete(j),K.abort.abort()),$e(void 0),o(pe()).then(()=>{if(X&&q(pe())===j)return Xe()}).catch(J=>{q(pe())===j&&$e(Tt(J))})});const ye=j=>{if(j.type==="failure")throw new Error(`${j.error.code}: ${j.error.message}`);return j.value},et=async j=>{Ae(void 0);try{return ye(await j())}catch(Q){Ae(Tt(Q))}},pt=()=>{const j=Le();be(j?.selection?.deviceId??j?.handle.deviceId??""),j&&De(j.handle.platform)},tt=pi({pending:te,error(j){Ae(Tt(j)),pt()}}),mt=pi({pending:he,error:j=>Ae(Tt(j))});ne.onCleanup(()=>{tt.cancel(),mt.cancel()});const Xe=async()=>{Ae(void 0);const j={serverID:ee.serverID,sessionID:ee.sessionID};await mt.run(Q=>T.list(j,{signal:Q}),Q=>{const K=ye(Q);if(K.type!=="devices"||(G(K.devices),Re()))return;if(Le()){dt()==="paused"&&Nt(J=>J+1);return}const X=Cn(Oe())??(!Ke&&!fe()?Cn(K.devices):void 0);X&&(De(X.platform),gt(X.id))})},Qt=async j=>{if(Ke=!0,j===Ge())return;tt.cancel(),De(j);const Q=Oe().find(K=>K.id===fe())??Cn(Oe());Q?await gt(Q.id):be("")},gt=async j=>{if(Re()&&j===fe())return;be(j),Ae(void 0);const Q=pe();await tt.run(async K=>{const X=de().find(J=>J.id===j);if(!X)throw new Error("The selected device is no longer available.");return await o(Q),K.throwIfAborted(),T.manual({scope:Q,operation:{type:"open",platform:X.platform,deviceId:X.id,boot:X.state==="shutdown"}},{signal:K})},K=>{K.type==="failure"&&K.error.code==="detached"?pt():ye(K)})};ne.createEffect(()=>{pe(),tt.cancel(),mt.cancel(),Xe()}),ne.createEffect(()=>{Je();const j=Qe(),Q=ue(),K=ne.untrack(Le);if(Pe=void 0,Bt(void 0),Fe("idle"),Q&&(Q.width=0,Q.height=0),!K||K.handle.token!==j||!Q||!K.capabilities.supported.includes("stream"))return;Ae(void 0);const X=new AbortController;let J;const ie=()=>!X.signal.aborted&&Qe()===j,Ye=Be=>{ie()&&(Fe("paused"),Ae(Tt(Be)))};(async()=>{try{const Be=await T.stream({scope:pe(),handle:K.handle},{signal:X.signal});if(!ie())return;if(Be.type==="failure")return Ye(`${Be.error.code}: ${Be.error.message}`);J=za({canvas:Q,stream:Be.stream,onState:St=>{ie()&&(Bt(St==="playing"?j:void 0),Fe(St))},onError:Ye}),Ce(J)}catch(Be){Ye(Be)}})(),ne.onCleanup(()=>{X.abort(),J?.destroy(),Ce(void 0)})}),ne.createEffect(()=>ht()?.active(Z.visible()));const Mt=j=>et(()=>T.manual({scope:pe(),operation:j})),Rt=j=>{const Q=ue();if(Q)return qa(Q.getBoundingClientRect(),Q,{x:j.clientX,y:j.clientY})},en=j=>{Pe=void 0;const Q=We();if(j.button!==0||!Q)return;const K=Rt(j),X=ue();!K||!X||(Pe={point:K,frame:Q,pointerId:j.pointerId},X.focus(),X.setPointerCapture(j.pointerId))},tn=j=>{const Q=Le(),K=Pe,X=Rt(j);if(Pe=void 0,!Q||!K||!X||K.pointerId!==j.pointerId||!Va(K.frame,We()))return;const J=K.point,ie={width:K.frame.width,height:K.frame.height};if(Math.hypot(X.x-J.x,X.y-J.y)<12){Mt({type:"tap",handle:Q.handle,point:X,viewport:ie});return}Mt({type:"swipe",handle:Q.handle,from:J,to:X,viewport:ie})},nn=()=>(()=>{var j=Qa(),Q=j.firstChild,K=Q.nextSibling,X=K.firstChild;return Y.insert(Q,Y.createComponent(ne.For,{get each(){return je.literals},children:J=>(()=>{var ie=ec();return ie.$$click=()=>{Qt(J)},Y.insert(ie,J==="android"?"Android":"iOS"),Y.effect(()=>Y.setAttribute(ie,"aria-pressed",Ge()===J)),ie})()})),K.addEventListener("change",J=>{gt(J.currentTarget.value)}),Y.insert(X,()=>Oe().length?"Select device":"No devices"),Y.insert(K,Y.createComponent(ne.For,{get each(){return Oe()},children:J=>(()=>{var ie=tc();return Y.insert(ie,()=>oc(J)),Y.effect(()=>ie.value=J.id),ie})()}),null),Y.insert(j,Y.createComponent(S.ui.Tooltip,{value:"Refresh devices",get children(){var J=Za();return J.$$click=()=>{Xe()},Y.insert(J,Y.createComponent(S.ui.Icon,{name:"refresh",size:"small"})),Y.effect(()=>Y.setAttribute(J,"aria-busy",ae())),J}}),null),Y.insert(j,Y.createComponent(S.ui.Tooltip,{get value(){return Le()?.agentAccess?"Revoke agent access for this session":"Allow agent access for this session"},get children(){return Y.createComponent(S.ui.Switch,{label:"Agent device access",hideLabel:!0,get checked(){return Le()?.agentAccess??!1},get disabled(){return!Le()},onChange:J=>{et(()=>T.access({scope:pe(),enabled:J}))}})}}),null),Y.effect(()=>K.disabled=Oe().length===0),Y.effect(()=>K.value=Oe().find(J=>J.id===fe())?.id??""),j})();return(()=>{var j=ic(),Q=j.firstChild,K=Q.firstChild;return K.addEventListener("pointercancel",()=>Pe=void 0),K.$$pointerup=tn,K.$$pointerdown=en,Y.use(Pt,K),Y.insert(Q,Y.createComponent(ne.Show,{get when(){return ft()},get children(){var X=nc();return Y.insert(X,ft),Y.effect(()=>X.classList.toggle("device-panel__viewer-state--pending",!!We())),X}}),null),Y.insert(Q,Y.createComponent(ne.Show,{get when(){return me()||Ee()},get children(){var X=rc(),J=X.firstChild;return Y.insert(X,Y.createComponent(S.ui.Icon,{name:"circle-exclamation",size:"small"}),J),Y.insert(J,()=>Ee()??me()),X}}),null),Y.insert(j,Y.createComponent(nn,{}),null),Y.effect(X=>{var J=!!ft(),ie=We()?"visible":"hidden";return J!==X.e&&Y.setAttribute(Q,"aria-busy",X.e=J),ie!==X.t&&Y.setStyleProperty(K,"visibility",X.t=ie),X},{e:void 0,t:void 0}),j})()};S.add(Ot.MenuItem,{menu:"session.panel",id:Lt,title:"Device",icon:"monitor",run:()=>{const ee=S.sessions.current();ee&&S.layout.open(`${S.id}:${Lt}:${crypto.randomUUID()}`,ee,{tab:"select"})}}),S.add(Ot.Panel,{id:Lt,region:"side",wide:!0,mobile:{title:"Device",order:40,kind:"menu",icon:"monitor",cached:!0},list:ee=>ee.open.filter(Z=>Z===Lt||Z.startsWith(`${Lt}:`)).map(Z=>({id:Z,title:"Device"})),render:ee=>Y.createComponent(le,{get sessionID(){return ee.session.id},get serverID(){return ee.session.server.id},get location(){return ee.session.location}})})},main(S){return Promise.resolve().then(()=>cc).then(I=>I.default(S))}});function Tt(S){return S instanceof Error?S.message:typeof S!="object"||S===null?String(S):"message"in S&&typeof S.message=="string"?S.message:"code"in S&&typeof S.code=="string"?S.code:String(S)}Y.delegateEvents(["click","pointerdown","pointerup"]);function ac(S){return(T=>{const B={exports:{}},q=B.exports;Object.defineProperties(q,{__esModule:{value:!0},[Symbol.toStringTag]:{value:"Module"}});const o=T("effect"),le=T("@opencode/schema/rpc"),ee=T("@opencode/plugin/gui"),Z=T("node:fs/promises"),de=T("node:os"),G=T("node:path"),fe=T("node:child_process"),be=T("node:string_decoder"),Ge=T("node:net"),De=T("node:timers/promises"),Ke=T("events"),Oe=T("https"),Re=T("http"),te=T("net"),ae=T("tls"),he=T("crypto"),Ee=T("stream"),Ae=T("url"),me=T("zlib"),$e=T("buffer"),dt=T("util"),Fe=T("node:crypto"),Ct=T("node:http"),Bt=T("node:https"),ht=8*1024*1024,Ce=o.Schema.optional,ue=o.Schema.String.check(o.Schema.isMaxLength(2048)),Pt=o.Schema.String.check(o.Schema.isMaxLength(1e5)),Je=o.Schema.Int.check(o.Schema.isGreaterThanOrEqualTo(0)),Nt=o.Schema.Int.check(o.Schema.isBetween({minimum:0,maximum:1e6})),pe=o.Schema.Literals(["ios","android"]).annotate({identifier:"Device.Platform"}),Le=o.Schema.Literals(["shutdown","booting","booted","unavailable"]).annotate({identifier:"Device.DeviceState"}),Qe=o.Schema.Literals(["available","owned-by-this-host","owned-by-other","unknown"]).annotate({identifier:"Device.Ownership"}),ut=o.Schema.Literals(["apps","launch","install","snapshot","press","fill","swipe","key","screenshot","stream"]).annotate({identifier:"Device.Capability"}),ft=o.Schema.Literals(["home","back","recents","lock","volumeUp","volumeDown"]).annotate({identifier:"Device.NavigationKey"}),Pe=Je.annotate({identifier:"Device.Generation"}),We=o.Schema.String.check(o.Schema.isPattern(/^dh_[a-f0-9-]{36}$/u)).pipe(o.Schema.brand("Device.HandleToken")).annotate({identifier:"Device.HandleToken"}),ye=o.Schema.Struct({token:We,platform:pe,deviceId:ue,generation:Pe}).annotate({identifier:"Device.DeviceHandle"}),et=o.Schema.String.check(o.Schema.isPattern(/^@?e[1-9][0-9]*$/u)).pipe(o.Schema.brand("Device.ElementRef")).annotate({identifier:"Device.ElementRef"}),pt=o.Schema.Struct({token:We,generation:Pe,revision:Je,ref:et}).annotate({identifier:"Device.SnapshotReference"}),tt=o.Schema.Struct({ref:Ce(et),role:ue,name:Ce(Pt),value:Ce(Pt),enabled:Ce(o.Schema.Boolean),focused:Ce(o.Schema.Boolean)}).annotate({identifier:"Device.AccessibilityNode"}),mt=o.Schema.Struct({token:We,generation:Pe,revision:Je,interactiveOnly:o.Schema.Boolean,complete:o.Schema.Boolean,nodes:o.Schema.Array(tt)}).annotate({identifier:"Device.Snapshot"}),Xe=o.Schema.Struct({x:Nt,y:Nt}).annotate({identifier:"Device.LogicalPoint"}),Qt=o.Schema.Struct({id:ue,name:ue,platform:pe,osVersion:Ce(ue),state:Le,ownership:Qe}).annotate({identifier:"Device.DeviceInfo"}),gt=o.Schema.Struct({supported:o.Schema.Array(ut),unsupported:o.Schema.Array(o.Schema.Struct({capability:ut,reason:ue}))}).annotate({identifier:"Device.Capabilities"}),Mt=o.Schema.Struct({id:ue,name:Ce(ue)}).annotate({identifier:"Device.AppInfo"}),Rt=o.Schema.Struct({app:ue,state:o.Schema.Literals(["launched","foreground","unknown"])}).annotate({identifier:"Device.LaunchResult"}),en=o.Schema.Struct({installed:o.Schema.Boolean,app:Ce(ue)}).annotate({identifier:"Device.InstallResult"}),tn=o.Schema.Struct({data:o.Schema.Uint8ArrayFromBase64.check(o.Schema.isMaxLength(ht)),width:Je,height:Je,deviceId:ue,platform:pe}).annotate({identifier:"Device.Screenshot"}),nn=o.Schema.Literal("h264").annotate({identifier:"Device.StreamProtocol"}),j=o.Schema.Struct({platform:pe,deviceId:ue,baseUrl:ue,token:ue,protocol:nn,loopback:o.Schema.Literal(!0)}).annotate({identifier:"Device.StreamDescriptor"}),Q=o.Schema.Literals(["missing-prerequisite","permission-denied","device-busy","detached","stale-reference","unsupported","not-found","invalid-artifact","timeout","helper-failed","internal"]).annotate({identifier:"Device.DeviceErrorCode"});function K(e,t){return e.token===t.token&&e.generation===t.generation&&e.platform===t.platform&&e.deviceId===t.deviceId}const X=o.Schema.Struct({code:Q,message:ue,mayHaveExecuted:o.Schema.Boolean}).annotate({identifier:"Device.DeviceError"}),J=o.Schema.optional,ie=o.Schema.String.check(o.Schema.isMaxLength(2048)),Ye=ie.check(o.Schema.isMinLength(1)),Ut={sessionID:Ye,connectionID:o.Schema.String},Be={...Ut,requestID:o.Schema.String},St=o.Schema.Number.check(o.Schema.isInt(),o.Schema.isBetween({minimum:1,maximum:1e6})),Un=o.Schema.optional(o.Schema.Struct({width:St,height:St})),nt=o.Schema.Struct({sessionID:Ye,serverID:ie,location:o.Schema.optionalKey(o.Schema.Struct({directory:ie}))}),jt=o.Schema.Struct({handle:ye,selection:o.Schema.optionalKey(o.Schema.Struct({platform:pe,deviceId:ie})),capabilities:gt,agentAccess:o.Schema.Boolean}).annotate({identifier:"DeviceBridge.Attachment"}),jn=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("list"),platform:J(pe)}),o.Schema.Struct({type:o.Schema.Literal("state")}),o.Schema.Struct({type:o.Schema.Literal("open"),platform:pe,deviceId:ie,boot:J(o.Schema.Boolean)}),o.Schema.Struct({type:o.Schema.Literal("apps"),handle:ye}),o.Schema.Struct({type:o.Schema.Literal("launch"),handle:ye,app:ie,deepLink:J(ie),relaunch:J(o.Schema.Boolean)}),o.Schema.Struct({type:o.Schema.Literal("install"),handle:ye,artifactPath:ie}),o.Schema.Struct({type:o.Schema.Literal("snapshot"),handle:ye,interactiveOnly:J(o.Schema.Boolean)}),o.Schema.Struct({type:o.Schema.Literal("press"),handle:ye,reference:pt}),o.Schema.Struct({type:o.Schema.Literal("tap"),handle:ye,point:Xe,viewport:Un}),o.Schema.Struct({type:o.Schema.Literal("fill"),handle:ye,reference:pt,text:ie}),o.Schema.Struct({type:o.Schema.Literal("swipe"),handle:ye,from:Xe,to:Xe,viewport:Un}),o.Schema.Struct({type:o.Schema.Literal("key"),handle:ye,key:ft}),o.Schema.Struct({type:o.Schema.Literal("screenshot"),handle:ye}),o.Schema.Struct({type:o.Schema.Literal("close"),handle:ye,shutdown:J(o.Schema.Boolean)})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Operation"}),wi=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("devices"),devices:o.Schema.Array(Qt)}),o.Schema.Struct({type:o.Schema.Literal("state"),state:o.Schema.NullOr(jt)}),o.Schema.Struct({type:o.Schema.Literal("attachment"),attachment:jt}),o.Schema.Struct({type:o.Schema.Literal("apps"),apps:o.Schema.Array(Mt)}),o.Schema.Struct({type:o.Schema.Literal("launch"),result:Rt}),o.Schema.Struct({type:o.Schema.Literal("install"),result:en}),o.Schema.Struct({type:o.Schema.Literal("snapshot"),snapshot:mt}),o.Schema.Struct({type:o.Schema.Literal("screenshot"),screenshot:tn}),o.Schema.Struct({type:o.Schema.Literal("done")})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Value"}),yt=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("success"),value:wi}),o.Schema.Struct({type:o.Schema.Literal("failure"),error:X})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Outcome"}),bi=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("success"),stream:j}),o.Schema.Struct({type:o.Schema.Literal("failure"),error:X})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.StreamOutcome"}),_i=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("attached"),connectionID:o.Schema.String,version:o.Schema.Literal(1)}),o.Schema.Struct({type:o.Schema.Literal("command"),connectionID:o.Schema.String,requestID:o.Schema.String}),o.Schema.Struct({type:o.Schema.Literal("cancel"),connectionID:o.Schema.String,requestID:o.Schema.String})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Control"}),Ne=o.Schema.toStandardSchemaV1,$t={unavailable:Ne(X)},rn=le.Rpc.define({id:"device.control",methods:{attach:{input:Ne(o.Schema.Struct({...Ut,version:o.Schema.Literal(1)})),output:Ne(o.Schema.Literals(["closed","replaced"])),errors:$t},state:{input:Ne(o.Schema.Struct({...Ut,state:o.Schema.NullOr(jt)})),output:Ne(o.Schema.Void),errors:$t},command:{input:Ne(o.Schema.Struct(Be)),output:Ne(jn),errors:$t},result:{input:Ne(o.Schema.Struct({...Be,outcome:yt})),output:Ne(o.Schema.Void),errors:$t}},events:{control:{schema:Ne(_i)}}}),$n=o.Schema.String.check(o.Schema.isMaxLength(2048)),ki=ee.Ipc.define({id:"demul.device.bridge.v2",state:o.Schema.Array(o.Schema.Struct({scope:nt,state:o.Schema.NullOr(jt)})),methods:{connect:{input:nt},disconnect:{input:nt},list:{input:o.Schema.Struct({platform:o.Schema.optional(pe),serverID:$n,sessionID:o.Schema.optionalKey($n)}),output:yt},access:{input:o.Schema.Struct({scope:nt,enabled:o.Schema.Boolean}),output:yt},manual:{input:o.Schema.Struct({scope:nt,operation:jn}),output:yt},stream:{input:o.Schema.Struct({scope:nt,handle:ye}),output:bi}}});class Fn extends Error{code;mayHaveExecuted;constructor(t){super(t.message),this.name="DeviceFailure",this.code=t.code,this.mayHaveExecuted=t.mayHaveExecuted}get data(){return{code:this.code,message:this.message,mayHaveExecuted:this.mayHaveExecuted}}}function P(e,t,n=!1){return new Fn({code:e,message:t,mayHaveExecuted:n})}function rt(e){return e instanceof Fn}function vt(e,t=!1){const n=e.reason instanceof Error&&e.reason.name==="TimeoutError";return P(n?"timeout":"detached",n?"The device operation exceeded its deadline.":"The device operation was cancelled.",t)}const Wn=12e4;function wt(e,t){return t?t.aborted?Promise.reject(t.reason):new Promise((n,r)=>{const i=()=>{t.removeEventListener("abort",i),r(t.reason)};t.addEventListener("abort",i,{once:!0}),e.then(n,r).finally(()=>t.removeEventListener("abort",i))}):e}class xi{pending=Promise.resolve();run(t,n){n?.throwIfAborted();const r=this.pending,i=wt(r,n).then(()=>(n?.throwIfAborted(),t())),s=i.then(()=>{},()=>{});return this.pending=r.then(()=>s),i}drain(){return this.pending}}const Ei=e=>["apps","snapshot","screenshot"].includes(e.type);function Ii(e,t=Wn){const n=new Map,r=new Map,i=new Map,s=new Map,a=new Map,h=new AbortController,l=u=>JSON.stringify([u.serverID,u.sessionID]),g=(u,c)=>JSON.stringify([u,c]),_=u=>{const c=r.get(u);return c&&"device"in c?c:void 0},O=(u,c)=>r.has(u)&&r.get(u)!==c,D=u=>({handle:u.device.handle,selection:{platform:u.selection.platform,deviceId:u.selection.deviceId},capabilities:u.device.capabilities,agentAccess:u.agentAccess}),R=(u,c=!1)=>{if(h.signal.aborted)throw P("detached","The device controller has stopped.");const d=n.get(l(u));if(!d)throw P("detached","Attach a device in the Device panel first.");if(d.state.type==="cleanup-failed"&&!c)throw P("detached","Device cleanup is incomplete; retry closing this attachment.");if(d.state.type==="cleanup")throw P("device-busy","This session is changing its device.");return d},F=(u,c,d,y=!1)=>{const x=R(u,y),N=x.device.handle;if(!K(N,c))throw P("permission-denied","This handle does not belong to this session's attached device.");if(d==="agent"&&!x.agentAccess)throw P("permission-denied","Enable agent access in the Device panel first.");return x},M=(u,c)=>{const d=l(u),y=(i.get(d)??Promise.resolve()).then(c),x=y.then(()=>{},()=>{});return i.set(d,x),x.then(()=>{i.get(d)===x&&i.delete(d)}),y},$=(u,c,d,y)=>{const x=l(u),N=g(c.platform,c.deviceId);s.get(x)?.abort();const U=new AbortController,A=AbortSignal.any([U.signal,...d?[d]:[]]);s.set(x,U);const ce=[...a].filter(([,Te])=>Te.session===x&&Te.device===N).map(([Te])=>Te),oe=Promise.all(ce).then(()=>(A.throwIfAborted(),y(A))),ke=oe.then(()=>{},()=>{});return a.set(ke,{session:x,device:N}),ke.then(()=>{a.delete(ke),s.get(x)===U&&s.delete(x)}),oe},k=u=>{r.forEach((c,d)=>{c===u&&r.delete(d)}),n.forEach((c,d)=>{c===u&&n.delete(d)})},E=(u,c,d=!1,y)=>{if(u.state.type==="released")return Promise.resolve();if(u.state.type==="cleanup")return u.state.pending;const x=u.state;x.type==="cleanup-failed"&&(c=x.reason,d||=x.shutdown);const N=u.queue.drain().then(async()=>{y?.aborted&&(u.state=x,y.throwIfAborted());try{await e.close({handle:u.device.handle,...d?{shutdown:d}:{}}),u.state={type:"released"},k(u)}catch(U){throw u.state={type:"cleanup-failed",reason:c,shutdown:d},U}});return u.state={type:"cleanup",reason:c,shutdown:d,pending:N},N},C=async u=>{u.state.type==="cleanup"&&await u.state.pending.catch(()=>{}),u.state.type==="cleanup-failed"&&await E(u,u.state.reason,u.state.shutdown)},W=async(u,c)=>{const d=_(g(c.platform,c.deviceId));d?.session===l(u)&&await C(d)},m=async(u,c,d)=>{const y=g(c.platform,c.deviceId);if(r.has(y))throw P("device-busy","This device is controlled by another session.");const x={session:l(u),state:{type:"reserved"}};r.set(y,x);try{d?.throwIfAborted();const N=await e.open(c,d),U={session:l(u),selection:c,device:N,queue:new xi,agentAccess:!0,state:{type:"preparing"}},A=g(N.handle.platform,N.handle.deviceId),ce=O(A,x);if(r.set(y,U),ce)throw await E(U,"rollback"),P("device-busy","This device is controlled by another session.");if(r.set(A,U),d?.aborted||h.signal.aborted)throw await E(U,"rollback",!0),d?.throwIfAborted(),P("detached","The device controller has stopped.");return U}finally{r.get(y)===x&&r.delete(y)}},v=(u,c,d,y,x,N=!1)=>{x?.throwIfAborted();const U=F(u,c,d),A=AbortSignal.any([h.signal,AbortSignal.timeout(t),...x?[x]:[]]);return U.queue.run(async()=>{F(u,c,d);try{const ce=await y(U,A);if(A.aborted)throw vt(A,N);return ce}catch(ce){throw rt(ce)?ce:A.aborted?vt(A,N):ce}},A)},f=async(u,c)=>{switch(u.type){case"apps":return{type:"apps",apps:await e.apps(u.handle,c)};case"snapshot":return{type:"snapshot",snapshot:await e.snapshot(u,c)};case"screenshot":return{type:"screenshot",screenshot:await e.screenshot(u.handle,c)}}},b=async(u,c)=>{switch(u.type){case"launch":return{type:"launch",result:await e.launch(u,c)};case"install":return{type:"install",result:await e.install(u,c)};case"press":await e.press(u,c);break;case"tap":await e.tap(u,c);break;case"fill":await e.fill(u,c);break;case"swipe":await e.swipe(u,c);break;case"key":await e.key(u,c)}return{type:"done"}};return{async list(u,c,d){if(h.signal.aborted)throw P("detached","The device controller has stopped.");const y=c?n.get(l(c)):void 0,x=await e.list(u,d);return d?.throwIfAborted(),x.map(N=>{const U=g(N.platform,N.id),A=_(U);return A?{...N,ownership:A===y||c&&A.session===l(c)?"owned-by-this-host":"owned-by-other"}:r.has(U)?{...N,ownership:"owned-by-other"}:N})},state(u){const c=n.get(l(u));return c?D(c):null},access(u,c){const d=R(u);return d.agentAccess=c,D(d)},async open(u,c,d,y){if(y?.throwIfAborted(),h.signal.aborted)throw P("detached","The device controller has stopped.");const x=n.get(l(u));if(x?.state.type==="attached"&&r.get(g(c.platform,c.deviceId))===x)return F(u,x.device.handle,d),d==="manual"&&s.get(l(u))?.abort(),D(x);if(d==="agent")throw P("permission-denied","Attach a device and enable agent access in the Device panel first.");return $(u,c,y,async N=>{await W(u,c),N.throwIfAborted();const U=await m(u,c,N);try{return await M(u,async()=>{N.throwIfAborted();const A=n.get(l(u));return U.agentAccess=A?.agentAccess??!0,U.state={type:"attached"},n.set(l(u),U),A&&E(A,"retire").catch(()=>{}),D(U)})}catch(A){throw await E(U,"rollback",!0),A}})},async stream(u,c,d){return v(u,c,"manual",(y,x)=>e.stream(y.device.handle,x),d)},async run(u,c,d,y){const x=Ei(c);return v(u,c.handle,d,(N,U)=>x?f(c,U):b(c,U),y,!x)},async close(u,c,d,y){return y?.throwIfAborted(),F(u,c.handle,d,!0),s.get(l(u))?.abort(),M(u,async()=>{y?.throwIfAborted();const x=F(u,c.handle,d,!0);await E(x,"close",c.shutdown,y)})},async detach(u){return s.get(l(u))?.abort(),M(u,async()=>{const c=n.get(l(u));c&&await E(c,"close")})},async dispose(){h.abort();for(const y of s.values())y.abort();await Promise.all(a.keys()),await Promise.all(i.values());const u=[...new Set(r.values())].filter(y=>"device"in y),c=await Promise.allSettled(u.map(C));await Promise.all(u.map(y=>y.queue.drain())),n.clear(),c.push(...await Promise.allSettled([e.dispose().then(()=>{for(const y of u)y.state.type==="attached"&&(y.state={type:"released"},k(y))})]));const d=c.find(y=>y.status==="rejected");if(d)throw d.reason}}}function He(e,t){return o.Schema.decodeUnknownOption(o.Schema.fromJsonString(e))(t)}const Hn=4*1024*1024;function Ft(e,t,n){const r=e+t;return r.length<=n?r:r.slice(r.length-n)}function ve(e){if(e.signal?.aborted)return Promise.reject(e.signal.reason);const t=Math.max(0,e.maxBytes??Hn);return new Promise((n,r)=>{const i=fe.spawn(e.command,[...e.args],{cwd:e.cwd,env:e.env?{...process.env,...e.env}:process.env,stdio:["pipe","pipe","pipe"]}),s=Vn(t),a=Vn(t);let h=!1,l=!1;const g=setTimeout(()=>{h=!0,i.kill("SIGKILL")},e.timeoutMs),_=()=>i.kill("SIGKILL");e.signal?.addEventListener("abort",_,{once:!0});const O=D=>{l||(l=!0,clearTimeout(g),e.signal?.removeEventListener("abort",_),e.signal?.aborted?r(e.signal.reason):n({...D,stdout:s.text(),stderr:a.text()}))};i.stdout?.on("data",D=>s.append(D)),i.stderr?.on("data",D=>a.append(D)),i.on("error",D=>O({code:null,signal:null,timedOut:h,spawnError:D.message})),i.on("close",(D,R)=>O({code:D,signal:R,timedOut:h})),e.input!==void 0?i.stdin?.end(e.input):i.stdin?.end()})}function Vn(e){const t=[];let n=0;return{append(r){for(t.push(r),n+=r.byteLength;n>e;){const i=t[0],s=Math.min(i.byteLength,n-e);s===i.byteLength?t.shift():t[0]=i.subarray(s),n-=s}},text:()=>Buffer.concat(t,n).toString("utf8")}}const Di=2e3,Li=2e3,Wt=new WeakMap;function zn(e,t=Di,n=Li){const r=Wt.get(e);if(r)return r;const i=(async()=>{try{e.stop("SIGTERM")}catch{}if(!await qn(e,t)){try{e.stop("SIGKILL")}catch{}if(!await qn(e,n))throw e.release?.(),P("timeout","The device helper did not exit after SIGTERM and SIGKILL within the cleanup deadline.")}})();return Wt.set(e,i),i.catch(()=>{Wt.get(e)===i&&Wt.delete(e)}),i}async function qn(e,t){let n;try{return await Promise.race([e.exited.then(()=>!0,()=>!1),new Promise(r=>{n=setTimeout(()=>r(!1),t)})])}finally{clearTimeout(n)}}function Gn(e){const t=fe.spawn(e.command,[...e.args],{cwd:e.cwd,env:e.env?{...process.env,...e.env}:process.env,stdio:["ignore","pipe","pipe"]});Kn(t.stdout,e.onStdoutLine,e.maxBytes),Kn(t.stderr,e.onStderrLine,e.maxBytes);const n=new Promise(r=>{t.on("error",i=>{e.onStderrLine?.(i.message),r({code:null,signal:null})}),t.on("close",(i,s)=>r({code:i,signal:s}))});return{pid:t.pid,exited:n,stop:(r="SIGTERM")=>{t.exitCode===null&&t.signalCode===null&&t.kill(r)},release:()=>{t.stdout?.destroy(),t.stderr?.destroy(),t.unref()}}}function Kn(e,t,n=Hn){if(!e)return;if(!t){e.resume();return}let r="";const i=new be.StringDecoder("utf8");e.on("data",s=>{r+=i.write(s);let a=r.indexOf(`
+"use strict";Object.defineProperties(exports,{__esModule:{value:!0},[Symbol.toStringTag]:{value:"Module"}});const Y=require("solid-js/web"),ne=require("solid-js"),Ot=require("@opencode/plugin/gui"),pa=require("@opencode/schema/rpc"),p=require("effect"),ma=8*1024*1024,qe=p.Schema.optional,we=p.Schema.String.check(p.Schema.isMaxLength(2048)),si=p.Schema.String.check(p.Schema.isMaxLength(1e5)),At=p.Schema.Int.check(p.Schema.isGreaterThanOrEqualTo(0)),ai=p.Schema.Int.check(p.Schema.isBetween({minimum:0,maximum:1e6})),je=p.Schema.Literals(["ios","android"]).annotate({identifier:"Device.Platform"}),ga=p.Schema.Literals(["shutdown","booting","booted","unavailable"]).annotate({identifier:"Device.DeviceState"}),Sa=p.Schema.Literals(["available","owned-by-this-host","owned-by-other","unknown"]).annotate({identifier:"Device.Ownership"}),ci=p.Schema.Literals(["apps","launch","install","snapshot","press","fill","swipe","key","screenshot","stream"]).annotate({identifier:"Device.Capability"}),ya=p.Schema.Literals(["home","back","recents","lock","volumeUp","volumeDown"]).annotate({identifier:"Device.NavigationKey"}),Nn=At.annotate({identifier:"Device.Generation"}),Mn=p.Schema.String.check(p.Schema.isPattern(/^dh_[a-f0-9-]{36}$/u)).pipe(p.Schema.brand("Device.HandleToken")).annotate({identifier:"Device.HandleToken"}),Ie=p.Schema.Struct({token:Mn,platform:je,deviceId:we,generation:Nn}).annotate({identifier:"Device.DeviceHandle"}),gi=p.Schema.String.check(p.Schema.isPattern(/^@?e[1-9][0-9]*$/u)).pipe(p.Schema.brand("Device.ElementRef")).annotate({identifier:"Device.ElementRef"}),li=p.Schema.Struct({token:Mn,generation:Nn,revision:At,ref:gi}).annotate({identifier:"Device.SnapshotReference"}),va=p.Schema.Struct({ref:qe(gi),role:we,name:qe(si),value:qe(si),enabled:qe(p.Schema.Boolean),focused:qe(p.Schema.Boolean)}).annotate({identifier:"Device.AccessibilityNode"}),wa=p.Schema.Struct({token:Mn,generation:Nn,revision:At,interactiveOnly:p.Schema.Boolean,complete:p.Schema.Boolean,nodes:p.Schema.Array(va)}).annotate({identifier:"Device.Snapshot"}),An=p.Schema.Struct({x:ai,y:ai}).annotate({identifier:"Device.LogicalPoint"}),ba=p.Schema.Struct({id:we,name:we,platform:je,osVersion:qe(we),state:ga,ownership:Sa}).annotate({identifier:"Device.DeviceInfo"}),_a=p.Schema.Struct({supported:p.Schema.Array(ci),unsupported:p.Schema.Array(p.Schema.Struct({capability:ci,reason:we}))}).annotate({identifier:"Device.Capabilities"}),ka=p.Schema.Struct({id:we,name:qe(we)}).annotate({identifier:"Device.AppInfo"}),xa=p.Schema.Struct({app:we,state:p.Schema.Literals(["launched","foreground","unknown"])}).annotate({identifier:"Device.LaunchResult"}),Ea=p.Schema.Struct({installed:p.Schema.Boolean,app:qe(we)}).annotate({identifier:"Device.InstallResult"}),Ia=p.Schema.Struct({data:p.Schema.Uint8ArrayFromBase64.check(p.Schema.isMaxLength(ma)),width:At,height:At,deviceId:we,platform:je}).annotate({identifier:"Device.Screenshot"}),Da=p.Schema.Literal("h264").annotate({identifier:"Device.StreamProtocol"}),La=p.Schema.Struct({platform:je,deviceId:we,baseUrl:we,token:we,protocol:Da,loopback:p.Schema.Literal(!0)}).annotate({identifier:"Device.StreamDescriptor"}),Ta=p.Schema.Literals(["missing-prerequisite","permission-denied","device-busy","detached","stale-reference","unsupported","not-found","invalid-artifact","timeout","helper-failed","internal"]).annotate({identifier:"Device.DeviceErrorCode"}),Rn=p.Schema.Struct({code:Ta,message:we,mayHaveExecuted:p.Schema.Boolean}).annotate({identifier:"Device.DeviceError"}),ct=p.Schema.optional,Ue=p.Schema.String.check(p.Schema.isMaxLength(2048)),Si=Ue.check(p.Schema.isMinLength(1)),Bn={sessionID:Si,connectionID:p.Schema.String},di={...Bn,requestID:p.Schema.String},hi=p.Schema.Number.check(p.Schema.isInt(),p.Schema.isBetween({minimum:1,maximum:1e6})),ui=p.Schema.optional(p.Schema.Struct({width:hi,height:hi})),lt=p.Schema.Struct({sessionID:Si,serverID:Ue,location:p.Schema.optionalKey(p.Schema.Struct({directory:Ue}))}),Yt=p.Schema.Struct({handle:Ie,selection:p.Schema.optionalKey(p.Schema.Struct({platform:je,deviceId:Ue})),capabilities:_a,agentAccess:p.Schema.Boolean}).annotate({identifier:"DeviceBridge.Attachment"}),yi=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("list"),platform:ct(je)}),p.Schema.Struct({type:p.Schema.Literal("state")}),p.Schema.Struct({type:p.Schema.Literal("open"),platform:je,deviceId:Ue,boot:ct(p.Schema.Boolean)}),p.Schema.Struct({type:p.Schema.Literal("apps"),handle:Ie}),p.Schema.Struct({type:p.Schema.Literal("launch"),handle:Ie,app:Ue,deepLink:ct(Ue),relaunch:ct(p.Schema.Boolean)}),p.Schema.Struct({type:p.Schema.Literal("install"),handle:Ie,artifactPath:Ue}),p.Schema.Struct({type:p.Schema.Literal("snapshot"),handle:Ie,interactiveOnly:ct(p.Schema.Boolean)}),p.Schema.Struct({type:p.Schema.Literal("press"),handle:Ie,reference:li}),p.Schema.Struct({type:p.Schema.Literal("tap"),handle:Ie,point:An,viewport:ui}),p.Schema.Struct({type:p.Schema.Literal("fill"),handle:Ie,reference:li,text:Ue}),p.Schema.Struct({type:p.Schema.Literal("swipe"),handle:Ie,from:An,to:An,viewport:ui}),p.Schema.Struct({type:p.Schema.Literal("key"),handle:Ie,key:ya}),p.Schema.Struct({type:p.Schema.Literal("screenshot"),handle:Ie}),p.Schema.Struct({type:p.Schema.Literal("close"),handle:Ie,shutdown:ct(p.Schema.Boolean)})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Operation"}),Oa=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("devices"),devices:p.Schema.Array(ba)}),p.Schema.Struct({type:p.Schema.Literal("state"),state:p.Schema.NullOr(Yt)}),p.Schema.Struct({type:p.Schema.Literal("attachment"),attachment:Yt}),p.Schema.Struct({type:p.Schema.Literal("apps"),apps:p.Schema.Array(ka)}),p.Schema.Struct({type:p.Schema.Literal("launch"),result:xa}),p.Schema.Struct({type:p.Schema.Literal("install"),result:Ea}),p.Schema.Struct({type:p.Schema.Literal("snapshot"),snapshot:wa}),p.Schema.Struct({type:p.Schema.Literal("screenshot"),screenshot:Ia}),p.Schema.Struct({type:p.Schema.Literal("done")})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Value"}),Xt=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("success"),value:Oa}),p.Schema.Struct({type:p.Schema.Literal("failure"),error:Rn})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Outcome"}),Aa=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("success"),stream:La}),p.Schema.Struct({type:p.Schema.Literal("failure"),error:Rn})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.StreamOutcome"}),Ca=p.Schema.Union([p.Schema.Struct({type:p.Schema.Literal("attached"),connectionID:p.Schema.String,version:p.Schema.Literal(1)}),p.Schema.Struct({type:p.Schema.Literal("command"),connectionID:p.Schema.String,requestID:p.Schema.String}),p.Schema.Struct({type:p.Schema.Literal("cancel"),connectionID:p.Schema.String,requestID:p.Schema.String})]).pipe(p.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Control"}),Me=p.Schema.toStandardSchemaV1,Jt={unavailable:Me(Rn)};pa.Rpc.define({id:"device.control",methods:{attach:{input:Me(p.Schema.Struct({...Bn,version:p.Schema.Literal(1)})),output:Me(p.Schema.Literals(["closed","replaced"])),errors:Jt},state:{input:Me(p.Schema.Struct({...Bn,state:p.Schema.NullOr(Yt)})),output:Me(p.Schema.Void),errors:Jt},command:{input:Me(p.Schema.Struct(di)),output:Me(yi),errors:Jt},result:{input:Me(p.Schema.Struct({...di,outcome:Xt})),output:Me(p.Schema.Void),errors:Jt}},events:{control:{schema:Me(Ca)}}});const fi=p.Schema.String.check(p.Schema.isMaxLength(2048)),Ba=Ot.Ipc.define({id:"demul.device.bridge.v2",state:p.Schema.Array(p.Schema.Struct({scope:lt,state:p.Schema.NullOr(Yt)})),methods:{connect:{input:lt},disconnect:{input:lt},list:{input:p.Schema.Struct({platform:p.Schema.optional(je),serverID:fi,sessionID:p.Schema.optionalKey(fi)}),output:Xt},access:{input:p.Schema.Struct({scope:lt,enabled:p.Schema.Boolean}),output:Xt},manual:{input:p.Schema.Struct({scope:lt,operation:yi}),output:Xt},stream:{input:p.Schema.Struct({scope:lt,handle:Ie}),output:Aa}}});function pi(S){let I;return{async run(T,B){I?.abort();const q=new AbortController;I=q,S.pending(!0);try{const o=await T(q.signal);I===q&&B(o)}catch(o){I===q&&!q.signal.aborted&&S.error(o)}finally{I===q&&(I=void 0,S.pending(!1))}},cancel(){I?.abort(),I=void 0,S.pending(!1)}}}const Pa=1397050709,Na={1:16,2:24},mi=new Uint8Array([0,0,0,1]);function Ma(S){const I=S instanceof Uint8Array?S:new Uint8Array(S);if(I.byteLength<4)return;const T=new DataView(I.buffer,I.byteOffset,I.byteLength);return T.getUint32(0)===Pa?Ra(I,T):vi(I,performance.now()*1e3,!1)}function Ra(S,I){if(S.byteLength<16)return;const T=Na[I.getUint8(4)];if(!T||S.byteLength<=T)return;const B=I.getBigUint64(8);if(!(B>BigInt(Number.MAX_SAFE_INTEGER)))return vi(S.subarray(T),Number(B),(I.getUint8(5)&1)===1,T===24?Number(I.getBigUint64(16))/1e3:void 0)}function vi(S,I,T,B){const q=Pn(S,0);if(q===void 0||q>=S.byteLength)return;const o=Ua(S);return{bytes:S,...o,key:o.key||o.picture&&T,timestamp:I,serverTimestamp:B}}function Ua(S){let I=!1,T=!1,B,q;for(const o of ja(S)){const le=o[0]&31;le===5&&(I=!0),le>=1&&le<=5&&(T=!0),le===7&&(B=o),le===8&&(q=o)}return{key:I,picture:T,codec:B&&$a(B),sps:B,pps:q}}function*ja(S){let I=Pn(S,0);if(I!==void 0){for(let T=I;T<S.byteLength-2;T++){const B=Pn(S,T);B!==void 0&&(T>I&&(yield S.subarray(I,T)),I=B,T=B-1)}I<S.byteLength&&(yield S.subarray(I))}}function Pn(S,I){if(!(S[I]!==0||S[I+1]!==0)){if(S[I+2]===1)return I+3;if(S[I+2]===0&&S[I+3]===1)return I+4}}function $a(S){if(!(S.byteLength<4))return`avc1.${[S[1],S[2],S[3]].map(I=>I.toString(16).padStart(2,"0")).join("")}`}class Fa{codec;sps;pps;update(I){I.sps&&(this.sps=I.sps.slice(),this.codec=I.codec),I.pps&&(this.pps=I.pps.slice())}bytes(I){if(!I.key)return I.bytes;const T=[];if(!I.sps&&this.sps&&T.push(mi,this.sps),!I.pps&&this.pps&&T.push(mi,this.pps),!T.length)return I.bytes;T.push(I.bytes);const B=new Uint8Array(T.reduce((o,le)=>o+le.byteLength,0));let q=0;for(const o of T)B.set(o,q),q+=o.byteLength;return B}clear(){this.codec=void 0,this.sps=void 0,this.pps=void 0}}async function Wa(S,I){const T=await VideoDecoder.isConfigSupported(S);if(!I.current())return;if(!T.supported)throw new Error(`H.264 codec ${S.codec} is not supported by this browser`);const B=new VideoDecoder({output(q){try{I.current()&&I.output(q)}catch(o){I.error(`Device video draw failed: ${o instanceof Error?o.message:String(o)}`)}finally{q.close()}},error(q){I.current()&&I.error(`H.264 decoder failed: ${q.message}`)}});try{B.configure(T.config??S)}catch(q){throw B.close(),new Error(`H.264 decoder configuration failed: ${q instanceof Error?q.message:String(q)}`)}return B}function Ha(S,I,T,B){if(!(!S||S!==I||T!=="playing"||!Zt(B)))return{token:S,width:B.width,height:B.height}}function Va(S,I){return!!I&&S.token===I.token&&S.width===I.width&&S.height===I.height}function za(S){let I=!1,T={type:"idle"};const B=()=>{try{return Ga(S)}catch(o){return S.onState("paused"),S.onError(o instanceof Error?o.message:String(o)),()=>{}}},q=()=>{if(T.type==="destroyed")return;const o=I&&document.visibilityState==="visible";if(o&&T.type==="idle"){T={type:"running",stop:B()};return}o||T.type!=="running"||(T.stop(),T={type:"idle"},S.onState(I?"paused":"idle"))};return document.addEventListener("visibilitychange",q),{active(o){T.type!=="destroyed"&&(I=o,q())},destroy(){if(T.type==="destroyed")return;const o=T;T={type:"destroyed"},document.removeEventListener("visibilitychange",q),o.type==="running"&&o.stop(),S.canvas.width=0,S.canvas.height=0,S.onState("idle")}}}function qa(S,I,T){if(![S.left,S.top,S.width,S.height,I.width,I.height,T.x,T.y].every(Number.isFinite)||S.width<=0||S.height<=0||!Zt(I))return;const B=Math.min(S.width/I.width,S.height/I.height),q=I.width*B,o=I.height*B,le=T.x-S.left-(S.width-q)/2,ee=T.y-S.top-(S.height-o)/2;if(!(le<0||ee<0||le>=q||ee>=o))return{x:Math.min(I.width-1,Math.floor(le/B)),y:Math.min(I.height-1,Math.floor(ee/B))}}function Ga(S){if(typeof VideoDecoder!="function"||typeof EncodedVideoChunk!="function")return S.onState("paused"),S.onError("H.264 device video requires WebCodecs support in this browser"),()=>{};const I=new URL("/video?frame-meta=1",new URL(S.stream.baseUrl).origin);I.protocol=I.protocol==="https:"?"wss:":"ws:";const T=new WebSocket(I,`opencode-device.${S.stream.token}`);let B={type:"waiting"};const q=new Fa;let o,le;const ee=()=>{clearTimeout(o),o=setTimeout(()=>fe("Device video did not produce a screen within 15 seconds. Refresh devices to retry."),15e3)};T.binaryType="arraybuffer",S.onState("connecting");const Z=()=>{if(T.readyState===WebSocket.OPEN)try{T.send(JSON.stringify({type:"reset-video",ack:!1}))}catch{}},de=(te=!1)=>{clearTimeout(le),le=void 0;const ae=B;B={type:"waiting"},"decoder"in ae&&ae.decoder.state!=="closed"&&ae.decoder.close(),te&&ae.type==="playing"&&(ee(),S.onState("connecting")),te&&Z()},G=()=>{B.type!=="stopped"&&(de(),B={type:"stopped"},clearTimeout(o),T.close())},fe=te=>{B.type!=="stopped"&&(G(),S.onError(te.replaceAll(S.stream.token,"[redacted]").slice(0,512)),S.onState("paused"))},be=(te,ae)=>{if(!(!("decoder"in B)||B.decoder!==ae||ae.state!=="configured")){B.waitingKeyframe=!1;try{le??=setTimeout(()=>{le=void 0,de(!0)},15e3),ae.decode(new EncodedVideoChunk({type:te.key?"key":"delta",timestamp:te.timestamp,data:q.bytes(te)}))}catch(he){fe(`H.264 decode failed: ${he instanceof Error?he.message:String(he)}`)}}},Ge=(te,ae)=>{de();const he={type:"configuring",codec:ae,missed:!1};B=he;const Ee=()=>B===he||"decoder"in B&&B.setup===he;Wa({codec:ae,optimizeForLatency:!0,hardwareAcceleration:"prefer-hardware"},{current:Ee,output(me){if(!("decoder"in B))return;const $e=B;clearTimeout(le),le=void 0,Ka(S,me,me.displayWidth,me.displayHeight),!(B!==$e||$e.type==="playing")&&(B={...$e,type:"playing"},clearTimeout(o),S.onState("playing"))},error:fe}).then(me=>{if(me){if(B!==he){me.close();return}B={type:"decoding",setup:he,decoder:me,waitingKeyframe:!0},be(te,me),Ee()&&"decoder"in B&&he.missed&&(B.waitingKeyframe=!0,Z())}}).catch(me=>{Ee()&&fe(`H.264 decoder setup failed: ${me instanceof Error?me.message:String(me)}`)})},De=()=>B.type==="configuring"?B.codec:"decoder"in B?B.setup.codec:void 0,Ke=te=>{q.update(te);const ae=De();ae&&q.codec!==ae&&de(!0)},Oe=te=>{const ae=q.codec??De();if(!ae)return Z();if("decoder"in B)return be(te,B.decoder);if(!te.key)return de(!0);Ge(te,ae)},Re=te=>{if(Ke(te),!!te.picture){if(B.type==="configuring"){B.missed=!0;return}if("decoder"in B&&B.decoder.decodeQueueSize>2)return de(!0);!te.key&&(!("decoder"in B)||B.waitingKeyframe)||Oe(te)}};return ee(),T.addEventListener("open",Z),T.addEventListener("message",te=>{if(B.type==="stopped")return;if(typeof te.data=="string"){const he=Ja(te.data);he?.type==="error"&&fe(`Device video failed: ${he.message}`),he?.type==="reset"&&(q.clear(),de(!0));return}if(!(te.data instanceof ArrayBuffer))return;const ae=Ma(te.data);ae&&Re(ae)}),T.addEventListener("error",()=>fe("Device video connection failed")),T.addEventListener("close",te=>{fe(`Device video connection closed (code ${te.code}). Refresh devices to retry.`)}),G}function Ka(S,I,T,B){if(!Zt({width:T,height:B}))throw new Error("Device video produced invalid screen dimensions");(S.canvas.width!==T||S.canvas.height!==B)&&(S.canvas.width=T,S.canvas.height=B);const q=S.canvas.getContext("2d",{alpha:!1});if(!q)throw new Error("Device video canvas is unavailable");q.drawImage(I,0,0,T,B)}function Ja(S){try{const I=JSON.parse(S);if(!I||typeof I!="object")return;if("ok"in I&&I.ok===!1)return{type:"error",message:"error"in I&&typeof I.error=="string"?I.error:"the capture session failed"};if(Xa(I))return{type:"reset"}}catch{return}}function Xa(S){return"type"in S&&S.type==="video-session"&&"size"in S&&S.size!==null&&typeof S.size=="object"&&Zt(S.size)}function Zt(S){return!("width"in S)||!("height"in S)?!1:typeof S.width=="number"&&typeof S.height=="number"&&Number.isSafeInteger(S.width)&&Number.isSafeInteger(S.height)&&S.width>0&&S.height>0}const Ya=".device-panel{box-sizing:border-box;display:flex;flex-direction:column;min-width:0;min-height:0;height:100%;color:var(--text-base);background:var(--background-base);overflow:hidden}.device-panel__picker{box-sizing:border-box;display:flex;align-items:center;justify-content:center;flex:none;gap:8px;width:100%;padding:12px}.device-panel__platforms{box-sizing:border-box;display:flex;flex:none;height:28px;border:1px solid var(--border-weak-base);border-radius:4px}.device-panel__platform,.device-panel__action{color:var(--text-base);background:transparent;cursor:pointer}.device-panel__platform:disabled,.device-panel__action:disabled{opacity:.5;cursor:default}.device-panel__platform{padding:0 8px;border:0;border-radius:3px;font:inherit;font-size:12px}.device-panel__platform[aria-pressed=true],.device-panel__platform:hover:not(:disabled){color:var(--text-strong);background:var(--background-stronger)}.device-panel__action{box-sizing:border-box;display:grid;place-items:center;flex:none;width:28px;height:28px;padding:0;border:1px solid var(--border-weak-base);border-radius:4px}.device-panel__action:hover:not(:disabled){background:var(--background-stronger)}.device-panel__device-select{flex:0 1 260px;width:260px}.device-panel select{box-sizing:border-box;min-width:0;height:28px;padding:0 24px 0 8px;color:var(--text-strong);background:var(--background-stronger);border:1px solid var(--border-weak-base);border-radius:4px;font:inherit;font-size:12px;text-overflow:ellipsis}.device-panel select:focus-visible,.device-panel__platform:focus-visible,.device-panel__action:focus-visible,.device-panel canvas:focus-visible{outline:2px solid var(--border-interactive-base);outline-offset:2px}.device-panel__error{position:absolute;inset:auto 12px 12px;display:flex;align-items:flex-start;gap:6px;padding:8px;color:var(--text-on-critical-weak);background:var(--surface-critical-weak);border-radius:4px;font-size:12px;overflow-wrap:anywhere}.device-panel__viewer{position:relative;display:grid;place-items:center;flex:1;min-width:0;min-height:0;overflow:hidden}.device-panel__viewer canvas{position:absolute;inset:0;display:block;width:100%;height:100%;object-fit:contain;touch-action:none;cursor:pointer}.device-panel__viewer-state{box-sizing:border-box;position:absolute;inset:0;display:flex;align-items:center;justify-content:center;gap:8px;padding:16px;color:var(--text-weak);background:color-mix(in srgb,var(--background-base) 88%,transparent);font-size:12px;text-align:center;overflow-wrap:anywhere;pointer-events:none}.device-panel__viewer-state--pending{inset:12px auto auto;padding:8px 12px;border-radius:4px;background:var(--background-base)}";var Za=Y.template('<button type=button class=device-panel__action aria-label="Refresh devices">'),Qa=Y.template('<footer class=device-panel__picker aria-label="Device selection"><div class=device-panel__platforms role=group aria-label="Device platform"></div><select class=device-panel__device-select aria-label=Device><option value disabled>'),ec=Y.template("<button type=button class=device-panel__platform>"),tc=Y.template("<option>"),nc=Y.template("<div class=device-panel__viewer-state role=status aria-live=polite aria-atomic=true>"),rc=Y.template("<div class=device-panel__error role=alert><span>"),ic=Y.template('<section class=device-panel aria-label="Device controls"><div class=device-panel__viewer><canvas aria-label="Live device screen"tabindex=0>');const Lt="device",Cn=S=>S.find(I=>I.ownership!=="owned-by-other"&&I.state==="booted")??S.find(I=>I.ownership!=="owned-by-other"&&I.state!=="unavailable"),oc=S=>S.platform==="ios"&&S.osVersion?`${S.name} (iOS ${S.osVersion})`:S.name,sc=Ot.Plugin.define({setup(S){const I=document.createElement("style");I.textContent=Ya,document.head.appendChild(I),ne.onCleanup(()=>I.remove());const T=S.main(Ba),B=new Map,q=ee=>JSON.stringify([ee.serverID,ee.sessionID]),o=ee=>{const Z=q(ee),de=B.get(Z);if(de)return de.ready;const G=new AbortController,fe=T.connect(ee,{signal:G.signal}).then(()=>{const be=B.get(Z);be?.abort===G&&(be.connected=!0)}).catch(be=>{throw B.get(Z)?.abort===G&&B.delete(Z),be});return B.set(Z,{scope:ee,abort:G,ready:fe,connected:!1}),fe};ne.createEffect(()=>{const ee=[...S.sessions.list(),S.sessions.current()];B.forEach((Z,de)=>{ee.some(G=>G?.id===Z.scope.sessionID&&G.server.id===Z.scope.serverID)||(B.delete(de),Z.abort.abort(),T.disconnect(Z.scope).catch(()=>{}))})}),ne.onCleanup(()=>{B.forEach(ee=>{ee.abort.abort(),T.disconnect(ee.scope).catch(()=>{})}),B.clear()});const le=ee=>{const Z=Ot.usePanel(),[de,G]=ne.createSignal([]),[fe,be]=ne.createSignal(""),[Ge,De]=ne.createSignal("android");let Ke=!1;const Oe=ne.createMemo(()=>de().filter(j=>j.platform===Ge())),[Re,te]=ne.createSignal(!1),[ae,he]=ne.createSignal(!1),[Ee,Ae]=ne.createSignal(),[me,$e]=ne.createSignal(),[dt,Fe]=ne.createSignal("idle"),[Ct,Bt]=ne.createSignal(),[ht,Ce]=ne.createSignal(),[ue,Pt]=ne.createSignal(),[Je,Nt]=ne.createSignal(0),pe=()=>({sessionID:ee.sessionID,serverID:ee.serverID,location:ee.location}),Le=()=>T.state()?.find(j=>q(j.scope)===q(pe()))?.state??void 0,Qe=ne.createMemo(()=>Le()?.handle.token);ne.createEffect(()=>{if(Qe(),ne.untrack(Re))return;const j=ne.untrack(Le);j&&(De(j.handle.platform),be(j.selection?.deviceId??j.handle.deviceId))});const ut=()=>de().find(j=>j.id===fe())?.state==="shutdown"?"Booting up device...":"Connecting to device...",ft=ne.createMemo(()=>{if(me()||Ee())return;if(Re())return ut();const j=Le();if(!j)return ae()?"Finding devices...":de().length===0?"No emulators or simulators found.":void 0;if(j.capabilities.supported.includes("stream")&&["idle","connecting"].includes(dt()))return"Almost done, preparing the screen..."});let Pe;const We=()=>{const j=ue();if(j)return Ha(Qe(),Ct(),dt(),j)};ne.createEffect(()=>{const j=q(pe()),Q=T.state()?.some(J=>q(J.scope)===j),K=B.get(j),X=K?.connected&&!Q;X&&(B.delete(j),K.abort.abort()),$e(void 0),o(pe()).then(()=>{if(X&&q(pe())===j)return Xe()}).catch(J=>{q(pe())===j&&$e(Tt(J))})});const ye=j=>{if(j.type==="failure")throw new Error(`${j.error.code}: ${j.error.message}`);return j.value},et=async j=>{Ae(void 0);try{return ye(await j())}catch(Q){Ae(Tt(Q))}},pt=()=>{const j=Le();be(j?.selection?.deviceId??j?.handle.deviceId??""),j&&De(j.handle.platform)},tt=pi({pending:te,error(j){Ae(Tt(j)),pt()}}),mt=pi({pending:he,error:j=>Ae(Tt(j))});ne.onCleanup(()=>{tt.cancel(),mt.cancel()});const Xe=async()=>{Ae(void 0);const j={serverID:ee.serverID,sessionID:ee.sessionID};await mt.run(Q=>T.list(j,{signal:Q}),Q=>{const K=ye(Q);if(K.type!=="devices"||(G(K.devices),Re()))return;if(Le()){dt()==="paused"&&Nt(J=>J+1);return}const X=Cn(Oe())??(!Ke&&!fe()?Cn(K.devices):void 0);X&&(De(X.platform),gt(X.id))})},Qt=async j=>{if(Ke=!0,j===Ge())return;tt.cancel(),De(j);const Q=Oe().find(K=>K.id===fe())??Cn(Oe());Q?await gt(Q.id):be("")},gt=async j=>{if(Re()&&j===fe())return;be(j),Ae(void 0);const Q=pe();await tt.run(async K=>{const X=de().find(J=>J.id===j);if(!X)throw new Error("The selected device is no longer available.");return await o(Q),K.throwIfAborted(),T.manual({scope:Q,operation:{type:"open",platform:X.platform,deviceId:X.id,boot:X.state==="shutdown"}},{signal:K})},K=>{K.type==="failure"&&K.error.code==="detached"?pt():ye(K)})};ne.createEffect(()=>{pe(),tt.cancel(),mt.cancel(),Xe()}),ne.createEffect(()=>{Je();const j=Qe(),Q=ue(),K=ne.untrack(Le);if(Pe=void 0,Bt(void 0),Fe("idle"),Q&&(Q.width=0,Q.height=0),!K||K.handle.token!==j||!Q||!K.capabilities.supported.includes("stream"))return;Ae(void 0);const X=new AbortController;let J;const ie=()=>!X.signal.aborted&&Qe()===j,Ye=Be=>{ie()&&(Fe("paused"),Ae(Tt(Be)))};(async()=>{try{const Be=await T.stream({scope:pe(),handle:K.handle},{signal:X.signal});if(!ie())return;if(Be.type==="failure")return Ye(`${Be.error.code}: ${Be.error.message}`);J=za({canvas:Q,stream:Be.stream,onState:St=>{ie()&&(Bt(St==="playing"?j:void 0),Fe(St))},onError:Ye}),Ce(J)}catch(Be){Ye(Be)}})(),ne.onCleanup(()=>{X.abort(),J?.destroy(),Ce(void 0)})}),ne.createEffect(()=>ht()?.active(Z.visible()));const Mt=j=>et(()=>T.manual({scope:pe(),operation:j})),Rt=j=>{const Q=ue();if(Q)return qa(Q.getBoundingClientRect(),Q,{x:j.clientX,y:j.clientY})},en=j=>{Pe=void 0;const Q=We();if(j.button!==0||!Q)return;const K=Rt(j),X=ue();!K||!X||(Pe={point:K,frame:Q,pointerId:j.pointerId},X.focus(),X.setPointerCapture(j.pointerId))},tn=j=>{const Q=Le(),K=Pe,X=Rt(j);if(Pe=void 0,!Q||!K||!X||K.pointerId!==j.pointerId||!Va(K.frame,We()))return;const J=K.point,ie={width:K.frame.width,height:K.frame.height};if(Math.hypot(X.x-J.x,X.y-J.y)<12){Mt({type:"tap",handle:Q.handle,point:X,viewport:ie});return}Mt({type:"swipe",handle:Q.handle,from:J,to:X,viewport:ie})},nn=()=>(()=>{var j=Qa(),Q=j.firstChild,K=Q.nextSibling,X=K.firstChild;return Y.insert(Q,Y.createComponent(ne.For,{get each(){return je.literals},children:J=>(()=>{var ie=ec();return ie.$$click=()=>{Qt(J)},Y.insert(ie,J==="android"?"Android":"iOS"),Y.effect(()=>Y.setAttribute(ie,"aria-pressed",Ge()===J)),ie})()})),K.addEventListener("change",J=>{gt(J.currentTarget.value)}),Y.insert(X,()=>Oe().length?"Select device":"No devices"),Y.insert(K,Y.createComponent(ne.For,{get each(){return Oe()},children:J=>(()=>{var ie=tc();return Y.insert(ie,()=>oc(J)),Y.effect(()=>ie.value=J.id),ie})()}),null),Y.insert(j,Y.createComponent(S.ui.Tooltip,{value:"Refresh devices",get children(){var J=Za();return J.$$click=()=>{Xe()},Y.insert(J,Y.createComponent(S.ui.Icon,{name:"refresh",size:"small"})),Y.effect(()=>Y.setAttribute(J,"aria-busy",ae())),J}}),null),Y.insert(j,Y.createComponent(S.ui.Tooltip,{get value(){return Le()?.agentAccess?"Revoke agent access for this session":"Allow agent access for this session"},get children(){return Y.createComponent(S.ui.Switch,{label:"Agent device access",hideLabel:!0,get checked(){return Le()?.agentAccess??!1},get disabled(){return!Le()},onChange:J=>{et(()=>T.access({scope:pe(),enabled:J}))}})}}),null),Y.effect(()=>K.disabled=Oe().length===0),Y.effect(()=>K.value=Oe().find(J=>J.id===fe())?.id??""),j})();return(()=>{var j=ic(),Q=j.firstChild,K=Q.firstChild;return K.addEventListener("pointercancel",()=>Pe=void 0),K.$$pointerup=tn,K.$$pointerdown=en,Y.use(Pt,K),Y.insert(Q,Y.createComponent(ne.Show,{get when(){return ft()},get children(){var X=nc();return Y.insert(X,ft),Y.effect(()=>X.classList.toggle("device-panel__viewer-state--pending",!!We())),X}}),null),Y.insert(Q,Y.createComponent(ne.Show,{get when(){return me()||Ee()},get children(){var X=rc(),J=X.firstChild;return Y.insert(X,Y.createComponent(S.ui.Icon,{name:"circle-exclamation",size:"small"}),J),Y.insert(J,()=>Ee()??me()),X}}),null),Y.insert(j,Y.createComponent(nn,{}),null),Y.effect(X=>{var J=!!ft(),ie=We()?"visible":"hidden";return J!==X.e&&Y.setAttribute(Q,"aria-busy",X.e=J),ie!==X.t&&Y.setStyleProperty(K,"visibility",X.t=ie),X},{e:void 0,t:void 0}),j})()};S.add(Ot.MenuItem,{menu:"session.panel",id:Lt,title:"Device",icon:"monitor",run:()=>{const ee=S.sessions.current();ee&&S.layout.open(`${S.id}:${Lt}:${crypto.randomUUID()}`,ee,{tab:"select"})}}),S.add(Ot.Panel,{id:Lt,region:"side",wide:!0,mobile:{title:"Device",order:40,kind:"menu",icon:"monitor",cached:!0},list:ee=>ee.open.filter(Z=>Z===Lt||Z.startsWith(`${Lt}:`)).map(Z=>({id:Z,title:"Device"})),render:ee=>Y.createComponent(le,{get sessionID(){return ee.session.id},get serverID(){return ee.session.server.id},get location(){return ee.session.location}})})},main(S){return Promise.resolve().then(()=>cc).then(I=>I.default(S))}});function Tt(S){return S instanceof Error?S.message:typeof S!="object"||S===null?String(S):"message"in S&&typeof S.message=="string"?S.message:"code"in S&&typeof S.code=="string"?S.code:String(S)}Y.delegateEvents(["click","pointerdown","pointerup"]);function ac(S){return(T=>{const B={exports:{}},q=B.exports;Object.defineProperties(q,{__esModule:{value:!0},[Symbol.toStringTag]:{value:"Module"}});const o=T("effect"),le=T("@opencode/schema/rpc"),ee=T("@opencode/plugin/gui"),Z=T("node:fs/promises"),de=T("node:os"),G=T("node:path"),fe=T("node:child_process"),be=T("node:string_decoder"),Ge=T("node:net"),De=T("node:timers/promises"),Ke=T("events"),Oe=T("https"),Re=T("http"),te=T("net"),ae=T("tls"),he=T("crypto"),Ee=T("stream"),Ae=T("url"),me=T("zlib"),$e=T("buffer"),dt=T("util"),Fe=T("node:crypto"),Ct=T("node:http"),Bt=T("node:https"),ht=8*1024*1024,Ce=o.Schema.optional,ue=o.Schema.String.check(o.Schema.isMaxLength(2048)),Pt=o.Schema.String.check(o.Schema.isMaxLength(1e5)),Je=o.Schema.Int.check(o.Schema.isGreaterThanOrEqualTo(0)),Nt=o.Schema.Int.check(o.Schema.isBetween({minimum:0,maximum:1e6})),pe=o.Schema.Literals(["ios","android"]).annotate({identifier:"Device.Platform"}),Le=o.Schema.Literals(["shutdown","booting","booted","unavailable"]).annotate({identifier:"Device.DeviceState"}),Qe=o.Schema.Literals(["available","owned-by-this-host","owned-by-other","unknown"]).annotate({identifier:"Device.Ownership"}),ut=o.Schema.Literals(["apps","launch","install","snapshot","press","fill","swipe","key","screenshot","stream"]).annotate({identifier:"Device.Capability"}),ft=o.Schema.Literals(["home","back","recents","lock","volumeUp","volumeDown"]).annotate({identifier:"Device.NavigationKey"}),Pe=Je.annotate({identifier:"Device.Generation"}),We=o.Schema.String.check(o.Schema.isPattern(/^dh_[a-f0-9-]{36}$/u)).pipe(o.Schema.brand("Device.HandleToken")).annotate({identifier:"Device.HandleToken"}),ye=o.Schema.Struct({token:We,platform:pe,deviceId:ue,generation:Pe}).annotate({identifier:"Device.DeviceHandle"}),et=o.Schema.String.check(o.Schema.isPattern(/^@?e[1-9][0-9]*$/u)).pipe(o.Schema.brand("Device.ElementRef")).annotate({identifier:"Device.ElementRef"}),pt=o.Schema.Struct({token:We,generation:Pe,revision:Je,ref:et}).annotate({identifier:"Device.SnapshotReference"}),tt=o.Schema.Struct({ref:Ce(et),role:ue,name:Ce(Pt),value:Ce(Pt),enabled:Ce(o.Schema.Boolean),focused:Ce(o.Schema.Boolean)}).annotate({identifier:"Device.AccessibilityNode"}),mt=o.Schema.Struct({token:We,generation:Pe,revision:Je,interactiveOnly:o.Schema.Boolean,complete:o.Schema.Boolean,nodes:o.Schema.Array(tt)}).annotate({identifier:"Device.Snapshot"}),Xe=o.Schema.Struct({x:Nt,y:Nt}).annotate({identifier:"Device.LogicalPoint"}),Qt=o.Schema.Struct({id:ue,name:ue,platform:pe,osVersion:Ce(ue),state:Le,ownership:Qe}).annotate({identifier:"Device.DeviceInfo"}),gt=o.Schema.Struct({supported:o.Schema.Array(ut),unsupported:o.Schema.Array(o.Schema.Struct({capability:ut,reason:ue}))}).annotate({identifier:"Device.Capabilities"}),Mt=o.Schema.Struct({id:ue,name:Ce(ue)}).annotate({identifier:"Device.AppInfo"}),Rt=o.Schema.Struct({app:ue,state:o.Schema.Literals(["launched","foreground","unknown"])}).annotate({identifier:"Device.LaunchResult"}),en=o.Schema.Struct({installed:o.Schema.Boolean,app:Ce(ue)}).annotate({identifier:"Device.InstallResult"}),tn=o.Schema.Struct({data:o.Schema.Uint8ArrayFromBase64.check(o.Schema.isMaxLength(ht)),width:Je,height:Je,deviceId:ue,platform:pe}).annotate({identifier:"Device.Screenshot"}),nn=o.Schema.Literal("h264").annotate({identifier:"Device.StreamProtocol"}),j=o.Schema.Struct({platform:pe,deviceId:ue,baseUrl:ue,token:ue,protocol:nn,loopback:o.Schema.Literal(!0)}).annotate({identifier:"Device.StreamDescriptor"}),Q=o.Schema.Literals(["missing-prerequisite","permission-denied","device-busy","detached","stale-reference","unsupported","not-found","invalid-artifact","timeout","helper-failed","internal"]).annotate({identifier:"Device.DeviceErrorCode"});function K(e,t){return e.token===t.token&&e.generation===t.generation&&e.platform===t.platform&&e.deviceId===t.deviceId}const X=o.Schema.Struct({code:Q,message:ue,mayHaveExecuted:o.Schema.Boolean}).annotate({identifier:"Device.DeviceError"}),J=o.Schema.optional,ie=o.Schema.String.check(o.Schema.isMaxLength(2048)),Ye=ie.check(o.Schema.isMinLength(1)),Ut={sessionID:Ye,connectionID:o.Schema.String},Be={...Ut,requestID:o.Schema.String},St=o.Schema.Number.check(o.Schema.isInt(),o.Schema.isBetween({minimum:1,maximum:1e6})),Un=o.Schema.optional(o.Schema.Struct({width:St,height:St})),nt=o.Schema.Struct({sessionID:Ye,serverID:ie,location:o.Schema.optionalKey(o.Schema.Struct({directory:ie}))}),jt=o.Schema.Struct({handle:ye,selection:o.Schema.optionalKey(o.Schema.Struct({platform:pe,deviceId:ie})),capabilities:gt,agentAccess:o.Schema.Boolean}).annotate({identifier:"DeviceBridge.Attachment"}),jn=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("list"),platform:J(pe)}),o.Schema.Struct({type:o.Schema.Literal("state")}),o.Schema.Struct({type:o.Schema.Literal("open"),platform:pe,deviceId:ie,boot:J(o.Schema.Boolean)}),o.Schema.Struct({type:o.Schema.Literal("apps"),handle:ye}),o.Schema.Struct({type:o.Schema.Literal("launch"),handle:ye,app:ie,deepLink:J(ie),relaunch:J(o.Schema.Boolean)}),o.Schema.Struct({type:o.Schema.Literal("install"),handle:ye,artifactPath:ie}),o.Schema.Struct({type:o.Schema.Literal("snapshot"),handle:ye,interactiveOnly:J(o.Schema.Boolean)}),o.Schema.Struct({type:o.Schema.Literal("press"),handle:ye,reference:pt}),o.Schema.Struct({type:o.Schema.Literal("tap"),handle:ye,point:Xe,viewport:Un}),o.Schema.Struct({type:o.Schema.Literal("fill"),handle:ye,reference:pt,text:ie}),o.Schema.Struct({type:o.Schema.Literal("swipe"),handle:ye,from:Xe,to:Xe,viewport:Un}),o.Schema.Struct({type:o.Schema.Literal("key"),handle:ye,key:ft}),o.Schema.Struct({type:o.Schema.Literal("screenshot"),handle:ye}),o.Schema.Struct({type:o.Schema.Literal("close"),handle:ye,shutdown:J(o.Schema.Boolean)})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Operation"}),wi=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("devices"),devices:o.Schema.Array(Qt)}),o.Schema.Struct({type:o.Schema.Literal("state"),state:o.Schema.NullOr(jt)}),o.Schema.Struct({type:o.Schema.Literal("attachment"),attachment:jt}),o.Schema.Struct({type:o.Schema.Literal("apps"),apps:o.Schema.Array(Mt)}),o.Schema.Struct({type:o.Schema.Literal("launch"),result:Rt}),o.Schema.Struct({type:o.Schema.Literal("install"),result:en}),o.Schema.Struct({type:o.Schema.Literal("snapshot"),snapshot:mt}),o.Schema.Struct({type:o.Schema.Literal("screenshot"),screenshot:tn}),o.Schema.Struct({type:o.Schema.Literal("done")})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Value"}),yt=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("success"),value:wi}),o.Schema.Struct({type:o.Schema.Literal("failure"),error:X})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Outcome"}),bi=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("success"),stream:j}),o.Schema.Struct({type:o.Schema.Literal("failure"),error:X})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.StreamOutcome"}),_i=o.Schema.Union([o.Schema.Struct({type:o.Schema.Literal("attached"),connectionID:o.Schema.String,version:o.Schema.Literal(1)}),o.Schema.Struct({type:o.Schema.Literal("command"),connectionID:o.Schema.String,requestID:o.Schema.String}),o.Schema.Struct({type:o.Schema.Literal("cancel"),connectionID:o.Schema.String,requestID:o.Schema.String})]).pipe(o.Schema.toTaggedUnion("type")).annotate({identifier:"DeviceBridge.Control"}),Ne=o.Schema.toStandardSchemaV1,$t={unavailable:Ne(X)},rn=le.Rpc.define({id:"device.control",methods:{attach:{input:Ne(o.Schema.Struct({...Ut,version:o.Schema.Literal(1)})),output:Ne(o.Schema.Literals(["closed","replaced"])),errors:$t},state:{input:Ne(o.Schema.Struct({...Ut,state:o.Schema.NullOr(jt)})),output:Ne(o.Schema.Void),errors:$t},command:{input:Ne(o.Schema.Struct(Be)),output:Ne(jn),errors:$t},result:{input:Ne(o.Schema.Struct({...Be,outcome:yt})),output:Ne(o.Schema.Void),errors:$t}},events:{control:{schema:Ne(_i)}}}),$n=o.Schema.String.check(o.Schema.isMaxLength(2048)),ki=ee.Ipc.define({id:"demul.device.bridge.v2",state:o.Schema.Array(o.Schema.Struct({scope:nt,state:o.Schema.NullOr(jt)})),methods:{connect:{input:nt},disconnect:{input:nt},list:{input:o.Schema.Struct({platform:o.Schema.optional(pe),serverID:$n,sessionID:o.Schema.optionalKey($n)}),output:yt},access:{input:o.Schema.Struct({scope:nt,enabled:o.Schema.Boolean}),output:yt},manual:{input:o.Schema.Struct({scope:nt,operation:jn}),output:yt},stream:{input:o.Schema.Struct({scope:nt,handle:ye}),output:bi}}});class Fn extends Error{code;mayHaveExecuted;constructor(t){super(t.message),this.name="DeviceFailure",this.code=t.code,this.mayHaveExecuted=t.mayHaveExecuted}get data(){return{code:this.code,message:this.message,mayHaveExecuted:this.mayHaveExecuted}}}function P(e,t,n=!1){return new Fn({code:e,message:t,mayHaveExecuted:n})}function rt(e){return e instanceof Fn}function vt(e,t=!1){const n=e.reason instanceof Error&&e.reason.name==="TimeoutError";return P(n?"timeout":"detached",n?"The device operation exceeded its deadline.":"The device operation was cancelled.",t)}const Wn=12e4;function wt(e,t){return t?t.aborted?Promise.reject(t.reason):new Promise((n,r)=>{const i=()=>{t.removeEventListener("abort",i),r(t.reason)};t.addEventListener("abort",i,{once:!0}),e.then(n,r).finally(()=>t.removeEventListener("abort",i))}):e}class xi{pending=Promise.resolve();run(t,n){n?.throwIfAborted();const r=this.pending,i=wt(r,n).then(()=>(n?.throwIfAborted(),t())),s=i.then(()=>{},()=>{});return this.pending=r.then(()=>s),i}drain(){return this.pending}}const Ei=e=>["apps","snapshot","screenshot"].includes(e.type);function Ii(e,t=Wn){const n=new Map,r=new Map,i=new Map,s=new Map,a=new Map,h=new AbortController,l=u=>JSON.stringify([u.serverID,u.sessionID]),g=(u,c)=>JSON.stringify([u,c]),_=u=>{const c=r.get(u);return c&&"device"in c?c:void 0},O=(u,c)=>r.has(u)&&r.get(u)!==c,D=u=>({handle:u.device.handle,selection:{platform:u.selection.platform,deviceId:u.selection.deviceId},capabilities:u.device.capabilities,agentAccess:u.agentAccess}),R=(u,c=!1)=>{if(h.signal.aborted)throw P("detached","The device controller has stopped.");const d=n.get(l(u));if(!d)throw P("detached","Attach a device in the Device panel first.");if(d.state.type==="cleanup-failed"&&!c)throw P("detached","Device cleanup is incomplete; retry closing this attachment.");if(d.state.type==="cleanup")throw P("device-busy","This session is changing its device.");return d},F=(u,c,d,y=!1)=>{const x=R(u,y),N=x.device.handle;if(!K(N,c))throw P("permission-denied","This handle does not belong to this session's attached device.");if(d==="agent"&&!x.agentAccess)throw P("permission-denied","Enable agent access in the Device panel first.");return x},M=(u,c)=>{const d=l(u),y=(i.get(d)??Promise.resolve()).then(c),x=y.then(()=>{},()=>{});return i.set(d,x),x.then(()=>{i.get(d)===x&&i.delete(d)}),y},$=(u,c,d,y)=>{const x=l(u),N=g(c.platform,c.deviceId);s.get(x)?.abort();const U=new AbortController,A=AbortSignal.any([U.signal,...d?[d]:[]]);s.set(x,U);const ce=[...a].filter(([,Te])=>Te.session===x&&Te.device===N).map(([Te])=>Te),oe=Promise.all(ce).then(()=>(A.throwIfAborted(),y(A))),ke=oe.then(()=>{},()=>{});return a.set(ke,{session:x,device:N}),ke.then(()=>{a.delete(ke),s.get(x)===U&&s.delete(x)}),oe},k=u=>{r.forEach((c,d)=>{c===u&&r.delete(d)}),n.forEach((c,d)=>{c===u&&n.delete(d)})},E=(u,c,d,y)=>{if(u.state.type==="released")return Promise.resolve();if(u.state.type==="cleanup")return u.state.pending;const x=u.state;x.type==="cleanup-failed"&&(c=x.reason,d??=x.shutdown),d??=!1;const N=u.queue.drain().then(async()=>{y?.aborted&&(u.state=x,y.throwIfAborted());try{await e.close({handle:u.device.handle,...d?{shutdown:d}:{}}),u.state={type:"released"},k(u)}catch(U){throw u.state={type:"cleanup-failed",reason:c,shutdown:d},U}});return u.state={type:"cleanup",reason:c,shutdown:d,pending:N},N},C=async u=>{u.state.type==="cleanup"&&await u.state.pending.catch(()=>{}),u.state.type==="cleanup-failed"&&await E(u,u.state.reason,u.state.shutdown)},W=async(u,c)=>{const d=_(g(c.platform,c.deviceId));d?.session===l(u)&&await C(d)},m=async(u,c,d)=>{const y=g(c.platform,c.deviceId);if(r.has(y))throw P("device-busy","This device is controlled by another session.");const x={session:l(u),state:{type:"reserved"}};r.set(y,x);try{d?.throwIfAborted();const N=await e.open(c,d),U={session:l(u),selection:c,device:N,queue:new xi,agentAccess:!0,state:{type:"preparing"}},A=g(N.handle.platform,N.handle.deviceId),ce=O(A,x);if(r.set(y,U),ce)throw await E(U,"rollback"),P("device-busy","This device is controlled by another session.");if(r.set(A,U),d?.aborted||h.signal.aborted)throw await E(U,"rollback",!0),d?.throwIfAborted(),P("detached","The device controller has stopped.");return U}finally{r.get(y)===x&&r.delete(y)}},v=(u,c,d,y,x,N=!1)=>{x?.throwIfAborted();const U=F(u,c,d),A=AbortSignal.any([h.signal,AbortSignal.timeout(t),...x?[x]:[]]);return U.queue.run(async()=>{F(u,c,d);try{const ce=await y(U,A);if(A.aborted)throw vt(A,N);return ce}catch(ce){throw rt(ce)?ce:A.aborted?vt(A,N):ce}},A)},f=async(u,c)=>{switch(u.type){case"apps":return{type:"apps",apps:await e.apps(u.handle,c)};case"snapshot":return{type:"snapshot",snapshot:await e.snapshot(u,c)};case"screenshot":return{type:"screenshot",screenshot:await e.screenshot(u.handle,c)}}},b=async(u,c)=>{switch(u.type){case"launch":return{type:"launch",result:await e.launch(u,c)};case"install":return{type:"install",result:await e.install(u,c)};case"press":await e.press(u,c);break;case"tap":await e.tap(u,c);break;case"fill":await e.fill(u,c);break;case"swipe":await e.swipe(u,c);break;case"key":await e.key(u,c)}return{type:"done"}};return{async list(u,c,d){if(h.signal.aborted)throw P("detached","The device controller has stopped.");const y=c?n.get(l(c)):void 0,x=await e.list(u,d);return d?.throwIfAborted(),x.map(N=>{const U=g(N.platform,N.id),A=_(U);return A?{...N,ownership:A===y||c&&A.session===l(c)?"owned-by-this-host":"owned-by-other"}:r.has(U)?{...N,ownership:"owned-by-other"}:N})},state(u){const c=n.get(l(u));return c?D(c):null},access(u,c){const d=R(u);return d.agentAccess=c,D(d)},async open(u,c,d,y){if(y?.throwIfAborted(),h.signal.aborted)throw P("detached","The device controller has stopped.");const x=n.get(l(u));if(x?.state.type==="attached"&&r.get(g(c.platform,c.deviceId))===x)return F(u,x.device.handle,d),d==="manual"&&s.get(l(u))?.abort(),D(x);if(d==="agent")throw P("permission-denied","Attach a device and enable agent access in the Device panel first.");return $(u,c,y,async N=>{await W(u,c),N.throwIfAborted();const U=await m(u,c,N);try{return await M(u,async()=>{N.throwIfAborted();const A=n.get(l(u));return U.agentAccess=A?.agentAccess??!0,U.state={type:"attached"},n.set(l(u),U),A&&E(A,"retire").catch(()=>{}),D(U)})}catch(A){throw await E(U,"rollback",!0),A}})},async stream(u,c,d){return v(u,c,"manual",(y,x)=>e.stream(y.device.handle,x),d)},async run(u,c,d,y){const x=Ei(c);return v(u,c.handle,d,(N,U)=>x?f(c,U):b(c,U),y,!x)},async close(u,c,d,y){return y?.throwIfAborted(),F(u,c.handle,d,!0),s.get(l(u))?.abort(),M(u,async()=>{y?.throwIfAborted();const x=F(u,c.handle,d,!0);await E(x,"close",c.shutdown,y)})},async detach(u){return s.get(l(u))?.abort(),M(u,async()=>{const c=n.get(l(u));c&&await E(c,"close")})},async dispose(){h.abort();for(const y of s.values())y.abort();await Promise.all(a.keys()),await Promise.all(i.values());const u=[...new Set(r.values())].filter(y=>"device"in y),c=await Promise.allSettled(u.map(C));await Promise.all(u.map(y=>y.queue.drain())),n.clear(),c.push(...await Promise.allSettled([e.dispose().then(()=>{for(const y of u)y.state.type==="attached"&&(y.state={type:"released"},k(y))})]));const d=c.find(y=>y.status==="rejected");if(d)throw d.reason}}}function He(e,t){return o.Schema.decodeUnknownOption(o.Schema.fromJsonString(e))(t)}const Hn=4*1024*1024;function Ft(e,t,n){const r=e+t;return r.length<=n?r:r.slice(r.length-n)}function ve(e){if(e.signal?.aborted)return Promise.reject(e.signal.reason);const t=Math.max(0,e.maxBytes??Hn);return new Promise((n,r)=>{const i=fe.spawn(e.command,[...e.args],{cwd:e.cwd,env:e.env?{...process.env,...e.env}:process.env,stdio:["pipe","pipe","pipe"]}),s=Vn(t),a=Vn(t);let h=!1,l=!1;const g=setTimeout(()=>{h=!0,i.kill("SIGKILL")},e.timeoutMs),_=()=>i.kill("SIGKILL");e.signal?.addEventListener("abort",_,{once:!0});const O=D=>{l||(l=!0,clearTimeout(g),e.signal?.removeEventListener("abort",_),e.signal?.aborted?r(e.signal.reason):n({...D,stdout:s.text(),stderr:a.text()}))};i.stdout?.on("data",D=>s.append(D)),i.stderr?.on("data",D=>a.append(D)),i.on("error",D=>O({code:null,signal:null,timedOut:h,spawnError:D.message})),i.on("close",(D,R)=>O({code:D,signal:R,timedOut:h})),e.input!==void 0?i.stdin?.end(e.input):i.stdin?.end()})}function Vn(e){const t=[];let n=0;return{append(r){for(t.push(r),n+=r.byteLength;n>e;){const i=t[0],s=Math.min(i.byteLength,n-e);s===i.byteLength?t.shift():t[0]=i.subarray(s),n-=s}},text:()=>Buffer.concat(t,n).toString("utf8")}}const Di=2e3,Li=2e3,Wt=new WeakMap;function zn(e,t=Di,n=Li){const r=Wt.get(e);if(r)return r;const i=(async()=>{try{e.stop("SIGTERM")}catch{}if(!await qn(e,t)){try{e.stop("SIGKILL")}catch{}if(!await qn(e,n))throw e.release?.(),P("timeout","The device helper did not exit after SIGTERM and SIGKILL within the cleanup deadline.")}})();return Wt.set(e,i),i.catch(()=>{Wt.get(e)===i&&Wt.delete(e)}),i}async function qn(e,t){let n;try{return await Promise.race([e.exited.then(()=>!0,()=>!1),new Promise(r=>{n=setTimeout(()=>r(!1),t)})])}finally{clearTimeout(n)}}function Gn(e){const t=fe.spawn(e.command,[...e.args],{cwd:e.cwd,env:e.env?{...process.env,...e.env}:process.env,stdio:["ignore","pipe","pipe"]});Kn(t.stdout,e.onStdoutLine,e.maxBytes),Kn(t.stderr,e.onStderrLine,e.maxBytes);const n=new Promise(r=>{t.on("error",i=>{e.onStderrLine?.(i.message),r({code:null,signal:null})}),t.on("close",(i,s)=>r({code:i,signal:s}))});return{pid:t.pid,exited:n,stop:(r="SIGTERM")=>{t.exitCode===null&&t.signalCode===null&&t.kill(r)},release:()=>{t.stdout?.destroy(),t.stderr?.destroy(),t.unref()}}}function Kn(e,t,n=Hn){if(!e)return;if(!t){e.resume();return}let r="";const i=new be.StringDecoder("utf8");e.on("data",s=>{r+=i.write(s);let a=r.indexOf(`
 `);for(;a!==-1;)t(Ft("",r.slice(0,a).replace(/\r$/u,""),n)),r=r.slice(a+1),a=r.indexOf(`
 `);r=Ft("",r,n)}),e.on("close",()=>{r=Ft(r,i.end(),n),r.length>0&&t(r.replace(/\r$/u,""))})}function Ti(e,t,n){const r=t?["open",e,t]:["open",e];return n?[...r,"--relaunch"]:r}function Oi(e){return e?["snapshot","-i","--json"]:["snapshot","--json"]}function Ai(e){return["press",e,"--settle"]}function Ci(e){return["press",String(e.x),String(e.y),"--settle"]}function Bi(e,t){return["fill",e,t,"--settle"]}function Pi(e,t){return["swipe",String(e.x),String(e.y),String(t.x),String(t.y)]}const Ni={home:["home"],back:["back","--settle"],recents:["app-switcher"],lock:["hardware-button","sleep"],volumeUp:["hardware-button","volume-up"],volumeDown:["hardware-button","volume-down"]};function Mi(e){return[...Ni[e]]}function Ri(e){return["screenshot",e]}function Ui(){return["apps","--all","--json"]}function ji(e){return["install",e]}function $i(){return["capabilities","--json"]}function Fi(){return["close"]}const Wi=o.Schema.Struct({ref:o.Schema.optional(o.Schema.String),kind:o.Schema.optional(o.Schema.String),type:o.Schema.optional(o.Schema.String),label:o.Schema.optional(o.Schema.String),value:o.Schema.optional(o.Schema.String),enabled:o.Schema.optional(o.Schema.Boolean),focused:o.Schema.optional(o.Schema.Boolean)}),Hi=o.Schema.Struct({data:o.Schema.Struct({nodes:o.Schema.Array(Wi),truncated:o.Schema.optional(o.Schema.Boolean)})}),Vi=o.Schema.decodeUnknownOption(et),zi=e=>e?Vi(e.startsWith("@")?e:`@${e}`):o.Option.none();function qi(e){const t=He(Hi,e);return o.Option.isNone(t)?null:{nodes:t.value.data.nodes.flatMap(n=>{const r=n.kind??n.type;if(!r)return[];const i=zi(n.ref);return[{role:r,...o.Option.isSome(i)?{ref:i.value}:{},...n.label?{name:n.label}:{},...n.value!==void 0?{value:n.value}:{},...n.enabled!==void 0?{enabled:n.enabled}:{},...n.focused!==void 0?{focused:n.focused}:{}}]}),complete:!(t.value.data.truncated??!1)}}const Gi=o.Schema.Struct({data:o.Schema.Struct({apps:o.Schema.Array(o.Schema.Union([o.Schema.String,o.Schema.Struct({id:o.Schema.optional(o.Schema.String),bundleId:o.Schema.optional(o.Schema.String),packageName:o.Schema.optional(o.Schema.String),name:o.Schema.optional(o.Schema.String),label:o.Schema.optional(o.Schema.String)})]))})}),Ki=/^(.+?)\s+\(([^()]+)\)\s*$/u;function Ji(e){const t=He(Gi,e);return o.Option.isNone(t)?null:t.value.data.apps.flatMap(n=>{if(typeof n=="string"){const s=n.match(Ki);return s?[{id:s[2],name:s[1]}]:n.trim()?[{id:n.trim()}]:[]}const r=n.id??n.bundleId??n.packageName;if(!r)return[];const i=n.name??n.label;return[i?{id:r,name:i}:{id:r}]})}const Xi=o.Schema.Struct({data:o.Schema.Struct({availableCommands:o.Schema.optional(o.Schema.Array(o.Schema.String))})}),Jn={apps:"apps",launch:"open",install:"install",snapshot:"snapshot",press:"press",fill:"fill",swipe:"swipe",key:"home",screenshot:"screenshot"};function Yi(e){const t=He(Xi,e);if(o.Option.isNone(t))return null;const n=new Set(t.value.data.availableCommands??[]);return Object.keys(Jn).filter(r=>n.has(Jn[r]))}const Zi=o.Schema.Struct({success:o.Schema.Literal(!1),error:o.Schema.Struct({code:o.Schema.String,message:o.Schema.String,hint:o.Schema.optional(o.Schema.String),details:o.Schema.optional(o.Schema.Struct({reason:o.Schema.optional(o.Schema.String),dispatched:o.Schema.optional(o.Schema.String)}))})});function Xn(e,t,n){const r=He(Zi,e.trim());if(o.Option.isNone(r))return null;const{code:i,message:s,hint:a,details:h={}}=r.value.error,l=h.dispatched==="no"?!1:n;if(h.reason==="ios_app_session_required")return P("missing-prerequisite",`${t} needs an app session on iOS; launch the app under test first.`,l);const g=`${t} failed: ${s}${a?` ${a}`:""}`;return i==="UNSUPPORTED_OPERATION"?P("unsupported",g,l):i.includes("TIMEOUT")||/timed out/iu.test(s)?P("timeout",g,l):P("helper-failed",g,l)}function Qi(e){const t=e.timeoutMs??Wn,n=["--platform",e.platform,e.platform==="android"?"--serial":"--udid",e.deviceId];return{run:(r,i,s)=>ve({command:e.externalNode,args:[e.agentDeviceBin,...r,...r.includes("--json")?[]:["--json"],...n],cwd:e.stateDir,env:e.env,timeoutMs:i??t,signal:s}),require:(r,i,s=!1)=>{if(r.timedOut)throw P("timeout",`${i} timed out.`,s);if(r.spawnError)throw P("helper-failed",`${i} could not start: ${r.spawnError}`);if(r.code!==0){const a=Xn(r.stdout,i,s)??Xn(r.stderr,i,s);if(a)throw a;const h=r.stderr.split(`
 `).filter(l=>l.trim()).slice(-2).join(" ")||r.stdout.trim();throw P("helper-failed",`${i} failed: ${h||`exit ${r.code}`}`,s)}return r}}}function Yn(e){return e.split(`
diff --git a/src/controller.test.ts b/src/controller.test.ts
index 3a62b06..426baab 100644
--- a/src/controller.test.ts
+++ b/src/controller.test.ts
@@ -153,8 +153,8 @@ test.each([false, true])(
   },
 );
 
-test.each(["close", "reopen"])(
-  "failed cleanup quarantines the handle and retains shutdown intent through %s",
+test.each(["close", "reopen", "detach"])(
+  "failed cleanup quarantines the handle and follows shutdown policy during %s",
   async (recovery) => {
     const item = fixture();
     const first = await item.controller.open(caller, selection, "manual");
@@ -173,8 +173,12 @@ test.each(["close", "reopen"])(
       item.controller.open({ ...caller, sessionID: "other" }, selection, "manual"),
     ).rejects.toMatchObject({ code: "device-busy" });
     item.runtime.close = close;
-    if (recovery === "close") {
-      await item.controller.close(caller, { handle: first.handle }, "manual");
+    if (recovery !== "reopen") {
+      await item.controller.close(
+        caller,
+        { handle: first.handle, ...(recovery === "detach" ? { shutdown: false } : {}) },
+        "manual",
+      );
       expect(item.controller.state(caller)).toBeNull();
       expect(item.calls).toEqual(["open", "close"]);
     } else {
@@ -182,7 +186,7 @@ test.each(["close", "reopen"])(
       expect(next.handle.token).not.toBe(first.handle.token);
       expect(item.calls).toEqual(["open", "close", "open"]);
     }
-    expect(item.closes[0]?.shutdown).toBe(true);
+    expect(item.closes[0]?.shutdown).toBe(recovery === "detach" ? undefined : true);
     await item.controller.dispose();
   },
 );
diff --git a/src/controller.ts b/src/controller.ts
index 1b07de0..18666a2 100644
--- a/src/controller.ts
+++ b/src/controller.ts
@@ -145,7 +145,7 @@ export function createDeviceController(
   const release = (
     entry: Attachment,
     reason: CleanupReason,
-    shutdown = false,
+    shutdown?: boolean,
     signal?: AbortSignal,
   ): Promise<void> => {
     if (entry.state.type === "released") return Promise.resolve();
@@ -153,8 +153,9 @@ export function createDeviceController(
     const previous = entry.state;
     if (previous.type === "cleanup-failed") {
       reason = previous.reason;
-      shutdown ||= previous.shutdown;
+      shutdown ??= previous.shutdown;
     }
+    shutdown ??= false;
     const pending = entry.queue.drain().then(async () => {
       if (signal?.aborted) {
         entry.state = previous;