Struct ValidationMessageProcessor

pub struct ValidationMessageProcessor;

A message processor that validates messages

This processor validates incoming and outgoing DIDComm messages to ensure they conform to the expected structure and protocol requirements.

In a production implementation, this would perform comprehensive validation including:

• Field validation (required fields, format, values)
• Protocol compliance checks for each message type
• Signature verification
• Timestamp and expiration checks
• Security and authorization checks

Implementation

Currently, this implementation validates:

• The message ID is not empty
• The message type is not empty
• Any ‘from’ or ‘to’ DIDs follow the ‘did:’ prefix format
• Basic protocol-specific requirements based on message type

Message Flow

The validator sits in the message processor pipeline and can filter out invalid messages by returning Ok(None), or let valid messages continue through the pipeline by returning Ok(Some(message)).

Trait Implementations

impl Clone for ValidationMessageProcessor

fn clone(&self) -> ValidationMessageProcessor

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ValidationMessageProcessor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl MessageProcessor for ValidationMessageProcessor

fn process_incoming<'life0, 'async_trait>( &'life0 self, message: Message, ) -> Pin<Box<dyn Future<Output = Result<Option<Message>>> + Send + 'async_trait>>

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

Process an incoming message received by the node

fn process_outgoing<'life0, 'async_trait>( &'life0 self, message: Message, ) -> Pin<Box<dyn Future<Output = Result<Option<Message>>> + Send + 'async_trait>>

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

Process an outgoing message being sent from the node