Method mark_sent

nodedb/src/control/array_sync/outbound/subscriber_state.rs:118–134

Update the cursor for `(session_id, array_name)` to `new_hlc`. Persists the updated state immediately so restarts pick up where delivery left off.

(&self, session_id: &str, array_name: &str, new_hlc: Hlc)

    /// Persists the updated state immediately so restarts pick up where
    /// delivery left off.
    pub fn mark_sent(&self, session_id: &str, array_name: &str, new_hlc: Hlc) {
        let key = (session_id.to_string(), array_name.to_string());
        let mut map = self.inner.write().unwrap_or_else(|p| p.into_inner());
        if let Some(state) = map.get_mut(&key)
            && new_hlc > state.last_pushed_hlc
        {
            state.last_pushed_hlc = new_hlc;
            if let Err(e) = self.store.save(state) {
                warn!(
                    session = %session_id,
                    array = %array_name,
                    error = %e,
                    "subscriber_state: failed to persist cursor — cursor will reset on restart"
                );
            }
        }
    }

    /// Remove all cursor entries for a session (disconnect cleanup).
    pub fn remove_session(&self, session_id: &str) {