Method subscribe

crates/opencode-server/src/pty.rs:297–317

Returns a snapshot of the current output buffer, the cumulative cursor position, a broadcast receiver for live output, and a clone of the PTY writer so the WebSocket handler can forward input. This is the primary integration point for the `/{id}/connect` WebSocket endpoint, mirroring the TS `Pty.connect` behaviour: - replay buffered output from a caller-supplied cursor - subscribe to live output

(&self, id: &str)

    ///   - subscribe to live output via the broadcast channel
    ///   - write user input into the PTY
    pub async fn subscribe(&self, id: &str) -> Result<PtySubscription, PtyError> {
        let sessions = self.sessions.read().await;
        let (_, inner) = sessions
            .get(id)
            .ok_or_else(|| PtyError::SessionNotFound(id.to_string()))?;

        let (buffer_snapshot, buffer_start, cursor) = {
            let buf = inner.output_buffer.lock().unwrap();
            let cursor = *inner.cursor.lock().unwrap();
            let buffer_start = cursor - buf.len();
            (buf.clone(), buffer_start, cursor)
        };

        Ok(PtySubscription {
            buffer: buffer_snapshot,
            buffer_start,
            cursor,
            rx: inner.output_tx.subscribe(),
            writer: inner.writer.clone(),
        })
    }
}

/// Handle returned by [`PtyManager::subscribe`] containing everything needed