Method push_event

src/cdp.rs:409–445

(&mut self, event: Value)

    }

    pub(crate) fn push_event(&mut self, event: Value) {
        // Only route events into the persistent buffers when the event's
        // sessionId matches the persistent page session (flatten-mode events
        // are tagged with sessionId). Events from ad-hoc sessions (sw-logs
        // attach, per-command live sessions) fall through and go into the
        // general events buffer — otherwise a subsequent page `console` drain
        // would return extension service worker logs.
        let from_persistent_session = self
            .persistent_session
            .as_deref()
            .is_some_and(|s| event["sessionId"].as_str() == Some(s));

        if from_persistent_session {
            let method = event.get("method").and_then(|v| v.as_str()).unwrap_or("");
            match method {
                "Network.requestWillBeSent"
                | "Network.responseReceived"
                | "Network.loadingFinished"
                | "Network.loadingFailed" => {
                    self.network_events.push_back(event);
                    if self.network_events.len() > MAX_PERSISTENT_EVENTS {
                        self.network_events.pop_front();
                    }
                    return;
                }
                "Runtime.consoleAPICalled" | "Runtime.exceptionThrown" => {
                    self.console_events.push_back(event);
                    if self.console_events.len() > MAX_PERSISTENT_EVENTS {
                        self.console_events.pop_front();
                    }
                    return;
                }
                _ => {}
            }
        }
        Self::push_to_buffer(&mut self.events, event);
    }

    fn push_to_buffer(events: &mut std::collections::VecDeque<Value>, event: Value) {
        events.push_back(event);