nodedb 0.3.0-beta.1

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

// SPDX-License-Identifier: BUSL-1.1

//! Change-stream enumeration for `PurgeCollection` cascade.
//!
//! Every change stream targets a specific collection via its
//! `collection` field. Wildcard / all-collections streams (if any)
//! are not enumerated here — they're expressed as a sentinel name
//! (empty string or `*`) and must survive a single-collection
//! cascade.

use crate::control::security::catalog::SystemCatalog;

/// Enumerate change streams targeting `(tenant_id, collection)`.
/// Returns stream names only, sorted.
pub fn find_change_streams_on(
    catalog: &SystemCatalog,
    tenant_id: u64,
    collection: &str,
) -> crate::Result<Vec<String>> {
    let all = catalog.load_all_change_streams()?;
    let mut out: Vec<String> = all
        .into_iter()
        .filter(|s| {
            s.tenant_id == tenant_id && s.collection == collection && !s.collection.is_empty()
        })
        .map(|s| s.name)
        .collect();
    out.sort();
    Ok(out)
}