Method record

packages/server/src/api/routes.rs:268–287

(&self, udid: &str, client_id: &str, foreground: bool)

impl StreamClientForegroundRegistry {
    pub fn record(&self, udid: &str, client_id: &str, foreground: bool) -> (bool, bool) {
        let now = Instant::now();
        let mut clients = self
            .inner
            .lock()
            .unwrap_or_else(|poisoned| poisoned.into_inner());
        clients.retain(|_, state| {
            now.duration_since(state.updated_at) <= STREAM_CLIENT_FOREGROUND_TTL
        });
        let previous = any_foreground_client_for_udid(&clients, udid);
        clients.insert(
            (udid.to_owned(), client_id.to_owned()),
            StreamClientForegroundState {
                foreground,
                updated_at: now,
            },
        );
        let next = any_foreground_client_for_udid(&clients, udid).unwrap_or(true);
        (next, previous != Some(next))
    }

    pub fn remove(&self, udid: &str, client_id: &str) -> (bool, bool) {
        let now = Instant::now();