Struct AntProtocol 

pub struct AntProtocol { /* private fields */ }

ANT protocol handler.

Handles chunk PUT/GET/Quote requests using LMDB storage for persistence and optional payment verification.

Implementations

impl AntProtocol

pub fn new( storage: Arc<LmdbStorage>, payment_verifier: Arc<PaymentVerifier>, quote_generator: Arc<QuoteGenerator>, ) -> Self

Create a new ANT protocol handler.

Arguments

• storage - LMDB storage for chunk persistence
• payment_verifier - Payment verifier for validating payments
• quote_generator - Quote generator for creating storage quotes

pub fn protocol_id(&self) -> &'static str

Get the protocol identifier.

pub async fn try_handle_request(&self, data: &[u8]) -> Result<Option<Bytes>>

Handle an incoming request and produce a response.

Decodes the raw message, processes it if it is a request variant, and returns the encoded response bytes. Returns Ok(None) for response messages (which are meant for client subscribers, not for the protocol handler).

Errors

Returns an error if message decoding, handling, or encoding fails.

pub fn storage_stats(&self) -> StorageStats

Get storage statistics.

pub fn payment_cache_stats(&self) -> CacheStats

Get payment cache statistics.

pub fn exists(&self, address: &[u8; 32]) -> Result<bool>

Check if a chunk exists locally.

Errors

Returns an error if the storage read fails.

pub async fn get_local(&self, address: &[u8; 32]) -> Result<Option<Vec<u8>>>

Get a chunk directly from local storage.

Errors

Returns an error if storage access fails.