Something went wrong. Try again.
very fast at protocol indexer with flexible filtering, xrpc queries, cursor-backed event stream, and more, built on fjall
rust fjall at-protocol atproto indexer
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394use serde::{Deserialize, Serialize};use smol_str::SmolStr;use std::sync::Arc;
pub(crate) type FilterHandle = Arc<arc_swap::ArcSwap<FilterConfig>>;
pub(crate) fn new_handle(config: FilterConfig) -> FilterHandle { Arc::new(arc_swap::ArcSwap::new(Arc::new(config)))}
#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]#[serde(rename_all = "snake_case")]pub enum FilterMode { Filter = 0, Full = 2,}
#[derive(Debug, Clone, Serialize)]pub(crate) struct FilterConfig { pub mode: FilterMode, pub signals: Vec<SmolStr>, pub collections: Vec<SmolStr>,}
impl FilterConfig { pub fn new(mode: FilterMode) -> Self { Self { mode, signals: Vec::new(), collections: Vec::new(), } }}
#[cfg(feature = "indexer")]mod indexer { use super::*;
impl FilterConfig { pub fn matches_collection(&self, collection: &str) -> bool { if self.collections.is_empty() { return true; } self.collections.iter().any(|p| nsid_matches(p, collection)) }
pub fn matches_signal(&self, collection: &str) -> bool { self.signals.iter().any(|p| nsid_matches(p, collection)) }
pub fn check_signals(&self) -> bool { self.mode == FilterMode::Filter && !self.signals.is_empty() } }
fn nsid_matches(pattern: &str, col: &str) -> bool { pattern .strip_suffix(".*") .map(|prefix| { col.strip_prefix(prefix) .is_some_and(|suffix| suffix.starts_with('.')) }) .unwrap_or_else(|| col == pattern) }}
#[cfg(all(test, feature = "indexer"))]mod tests { use super::*;
#[test] fn wildcard_matches_on_nsid_boundaries() { let mut filter = FilterConfig::new(FilterMode::Filter); filter.collections.push(SmolStr::new("sh.tangled.*"));
assert!(filter.matches_collection("sh.tangled.repo")); assert!(filter.matches_collection("sh.tangled.repo.issue")); assert!(!filter.matches_collection("sh.tangledfoo.repo")); assert!(!filter.matches_collection("sh.tangled")); } #[test] fn filter_mode_persisted_golden_fixtures() { for (mode, msgpack, json) in [ (FilterMode::Filter, "a666696c746572", "\"filter\""), (FilterMode::Full, "a466756c6c", "\"full\""), ] { let encoded = rmp_serde::to_vec(&mode).unwrap(); assert_eq!(data_encoding::HEXLOWER.encode(&encoded), msgpack); assert_eq!(rmp_serde::from_slice::<FilterMode>(&encoded).unwrap(), mode); assert_eq!(serde_json::to_string(&mode).unwrap(), json); } }}