Struct PeerScoringService 

pub struct PeerScoringService<S: PeerScoreStorage> { /* private fields */ }

Per-conversation, per-member score tracker. Reference PeerScoringPlugin implementation. One instance per conversation; threshold travels with ScoringConfig. Storage is abstracted via PeerScoreStorage so app-layer backends (in-memory, on-disk, …) plug in without touching this protocol logic.

Implementations

impl<S: PeerScoreStorage> PeerScoringService<S>

pub fn new( storage: S, score_deltas: HashMap<ScoreEvent, i64>, config: ScoringConfig, ) -> Self

Trait Implementations

impl<S: PeerScoreStorage> PeerScoringPlugin for PeerScoringService<S>

fn add_member(&mut self, member_id: &[u8]) -> Vec<PeerScoringEvent>

Start tracking a member at the plug-in’s default score.

fn remove_member(&mut self, member_id: &[u8])

Stop tracking a member. Emits no events — removal is a membership change, not a score event. Idempotent: a no-op on an untracked member.

fn apply_op(&mut self, op: &ScoreOp) -> Vec<PeerScoringEvent>

Apply a single ScoreOp. Untracked members are no-ops (no event, no auto-tracking — coordinators must call Self::add_member before applying ops). Returns events only when the op causes a threshold cross; repeated ops on a member already at-or-below threshold do not re-emit.

fn apply_snapshot(&mut self, snapshot: &ScoreSnapshot) -> Vec<PeerScoringEvent>

Apply a snapshot of absolute scores (ConversationSync bootstrap). Unknown members are auto-tracked at the snapshot value — unlike Self::apply_op, which ignores them — because a snapshot may arrive before the MLS membership view catches up.

fn snapshot(&self) -> ScoreSnapshot

Sparse snapshot of non-default scores for ConversationSync send.

fn score_for(&self, member_id: &[u8]) -> Option<i64>

fn members_below_threshold(&self) -> Vec<Vec<u8>>

fn all_members_with_scores(&self) -> Vec<(Vec<u8>, i64)>

fn threshold(&self) -> i64

Current removal threshold. Coordinator reads this when building ConversationSync so joiners adopt the same value.

fn set_threshold(&mut self, threshold: i64)

Update the threshold in place. Emits NO events — even though a tightened threshold can re-classify members from above to at-or-below, the plug-in does not retroactively scan and emit. Event-driven coordinators MUST re-scan Self::members_below_threshold after a set_threshold call, or arrange for a subsequent apply that surfaces the affected members through normal cross-detection.

fn default_score(&self) -> i64

Starting score for a newly tracked member. Called by Self::add_member and on apply_snapshot for unknown identities.

fn set_default_score(&mut self, score: i64)

Update the starting score in place. Applies to future Self::add_member calls; does not retroactively rescore already-tracked members.

fn apply_ops(&mut self, ops: &[ScoreOp]) -> Vec<PeerScoringEvent>

Apply a batch of ScoreOps. Returns the concatenated events for every op in input order. A member crossing threshold twice in one batch (down then up, say) yields two events in that order. Default impl chains Self::apply_op; override for batched-write storage where the round-trip cost dominates.