intrepid_core/extract/
message_uri.rs

1use crate::{Context, Frame};
2
3use super::{Extractor, Message, MessageFrameError};
4
5/// Extract the URI of a message from a frame.
6#[derive(Debug, Clone, PartialEq, Eq)]
7pub struct MessageUri(pub String);
8
9impl<State> Extractor<State> for MessageUri {
10    type Error = MessageFrameError;
11
12    fn extract(frame: Frame, context: &Context<State>) -> Result<Self, Self::Error>
13    where
14        Self: Sized,
15    {
16        let Message(message_frame) = Message::extract(frame, context)?;
17
18        Ok(Self(message_frame.uri))
19    }
20}
21
22#[test]
23fn message_uri() -> Result<(), MessageFrameError> {
24    let frame = Frame::message("/test", (), ());
25    let context = Context::<()>::default();
26    let MessageUri(message_uri) = MessageUri::extract(frame, &context)?;
27
28    assert_eq!(message_uri, "/test");
29
30    Ok(())
31}
32
33#[test]
34fn failure() -> Result<(), MessageFrameError> {
35    use crate::{Error, ExtractorError};
36
37    let context = Context::<()>::default();
38    let result = MessageUri::extract_from_frame_and_state(Frame::default(), &context);
39
40    assert!(matches!(
41        result.unwrap_err(),
42        Error::ExtractorError(ExtractorError::MessageFrameError(
43            MessageFrameError::WrongFrame(_)
44        ))
45    ),);
46
47    Ok(())
48}
intrepid_core/extract/message_uri.rs

intrepid_core/extract/
message_uri.rs
