Method open_relay

crates/openshell-server/src/supervisor_session.rs:236–254

Open a relay channel and return a receiver for the supervisor-side stream. Sends `RelayOpen` over the supervisor's gRPC session and returns a oneshot receiver that resolves once the supervisor opens its reverse HTTP CONNECT to `/relay/{channel_id}`. If the session is not currently registered, this method waits up to `session_wait_timeout` for it to appear. A session may be temporarily absent for

(
        &self,
        sandbox_id: &str,
        session_wait_timeout: Duration,
    )

    /// seconds on a slow cluster), while mid-lifetime calls typically just
    /// need to cover a short reconnect window.
    pub async fn open_relay(
        &self,
        sandbox_id: &str,
        session_wait_timeout: Duration,
    ) -> Result<
        (
            String,
            oneshot::Receiver<Result<tokio::io::DuplexStream, Status>>,
        ),
        Status,
    > {
        self.open_relay_with_target(
            sandbox_id,
            relay_open::Target::Ssh(SshRelayTarget {}),
            String::new(),
            session_wait_timeout,
        )
        .await
    }

    pub async fn open_relay_with_target(
        &self,