Struct RemoteCapsuleReceiver 

pub struct RemoteCapsuleReceiver { /* private fields */ }

Drives the receive → score → promote/quarantine pipeline for remote capsules.

Usage

let receiver = RemoteCapsuleReceiver::new("/tmp/audit.jsonl", None);
let disposition = receiver.on_capsule_received(&capsule, &gene);

Implementations

impl RemoteCapsuleReceiver

pub fn new( audit_log_path: Option<impl AsRef<Path>>, threshold: Option<f64>, ) -> Self

Create a new receiver.

• audit_log_path — if Some, every decision is appended as a JSONL line to that file.
• threshold — override the default PROMOTE_THRESHOLD (0.70).

pub fn with_rate_limit_config( audit_log_path: Option<impl AsRef<Path>>, threshold: Option<f64>, rate_limit_config: PeerRateLimitConfig, ) -> Self

pub fn on_capsule_received( &self, capsule: &Capsule, gene: &mut Gene, ) -> CapsuleDisposition

Evaluate a received capsule and return the promotion decision.

Steps:

1. Verify signature (placeholder — always passes until P3-02).
2. Use the capsule’s own confidence field as the composite score.
3. If score >= threshold: set gene.state = Promoted and return CapsuleDisposition::Promoted.
4. Otherwise: return CapsuleDisposition::Quarantined { reason: LowScore }.
5. Append an audit entry to capsule_audit_log.jsonl.

The caller is responsible for persisting the promoted gene to a gene store (e.g. GeneStore::upsert_gene). The returned CapsuleDisposition carries the promoted gene_id so the caller can act accordingly.

pub fn on_signed_capsule_received( &self, peer_id: &str, public_key_hex: &str, envelope: &EvolutionEnvelope, capsule: &Capsule, gene: &mut Gene, ) -> Result<CapsuleDisposition, RejectionReason>

pub fn network_audit_trail(&self) -> Vec<NetworkAuditEntry>

pub fn audit_trail(&self) -> Vec<(String, CapsuleDisposition)>

All in-memory audit entries accumulated so far.

pub fn audit_count(&self) -> usize

Number of audit entries recorded.

Trait Implementations

impl Default for RemoteCapsuleReceiver

fn default() -> Self

Returns the “default value” for a type.