Struct FaultyNoteTransportApi 

pub struct FaultyNoteTransportApi { /* private fields */ }

Available on crate feature testing only.

Test-only NoteTransportClient decorator that injects controlled failures into send_note calls.

Reproduces the failure mode where the NTL is reachable but rejects (or silently drops) a relay attempt, exercising the durable outbox in Client::send_private_note: without retry/persistence a failed relay would leave the recipient unable to discover the note.

The decorator counts attempts (send_attempts) and lets a test specify how many of the next send_note calls should fail (fail_next); successful calls delegate to an inner MockNoteTransportApi. fetch_notes failures can be injected separately via FaultyNoteTransportApi::fail_next_n_fetches; stream_notes always delegates to the inner mock.

Implementations

impl FaultyNoteTransportApi

pub fn new( mock_node: Arc<RwLock<MockNoteTransportNode>>, fail_next: usize, ) -> Self

Create a faulty transport that fails the next fail_next send_note calls before delegating to the inner mock.

pub fn fail_next_n(&self, n: usize)

Reset the fail-counter to n; subsequent send_note calls fail until the counter reaches zero.

pub fn send_attempts(&self) -> usize

Total send_note calls observed (success + failure).

pub fn fail_next_n_fetches(&self, n: usize)

Fail the next n fetch_notes calls before delegating to the inner mock again.

pub fn fetch_attempts(&self) -> usize

Total fetch_notes calls observed (success + failure).

Trait Implementations

impl NoteTransportClient for FaultyNoteTransportApi

fn send_note<'life0, 'async_trait>( &'life0 self, header: NoteHeader, details: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), NoteTransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a note with optionally encrypted details

fn send_note_with_block_hint<'life0, 'async_trait>( &'life0 self, header: NoteHeader, details: Vec<u8>, block_hint: BlockNumber, ) -> Pin<Box<dyn Future<Output = Result<(), NoteTransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a note, relaying a block hint for the recipient’s commitment scan.

fn fetch_notes<'life0, 'life1, 'async_trait>( &'life0 self, tags: &'life1 [NoteTag], cursor: NoteTransportCursor, ) -> Pin<Box<dyn Future<Output = Result<(Vec<NoteInfo>, NoteTransportCursor), NoteTransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch notes for given tags

fn stream_notes<'life0, 'async_trait>( &'life0 self, _tag: NoteTag, _cursor: NoteTransportCursor, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn NoteStream>, NoteTransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stream notes for a given tag