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 async fn handle_message(&self, data: &[u8]) -> Result<Bytes>

Handle an incoming protocol message.

Deprecated: Use try_handle_request instead. This method always returns response bytes — even for response messages that should be ignored — which can create an infinite ping-pong loop if the caller blindly sends the result back.

Errors

Returns an error if message decoding or handling 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.