1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

use crate::message::commands::ServerMessageParseError;
use crate::message::IRCMessage;
use std::convert::TryFrom;

/// A `PONG` connection-control message.
#[derive(Debug, Clone, PartialEq)]
pub struct PongMessage {
    /// The message that this `PongMessage` was parsed from.
    pub source: IRCMessage,
}

impl TryFrom<IRCMessage> for PongMessage {
    type Error = ServerMessageParseError;

    fn try_from(source: IRCMessage) -> Result<PongMessage, ServerMessageParseError> {
        if source.command != "PONG" {
            return Err(ServerMessageParseError::MismatchedCommand(source));
        }

        Ok(PongMessage { source })
    }
}

impl From<PongMessage> for IRCMessage {
    fn from(msg: PongMessage) -> IRCMessage {
        msg.source
    }
}

#[cfg(test)]
mod tests {
    use crate::message::{IRCMessage, PongMessage};
    use std::convert::TryFrom;

    #[test]
    pub fn test_basic() {
        // this is what the Twitch servers answers "PING" with
        let src = "PONG :tmi.twitch.tv";
        let irc_message = IRCMessage::parse(src).unwrap();
        let msg = PongMessage::try_from(irc_message.clone()).unwrap();

        assert_eq!(
            msg,
            PongMessage {
                source: irc_message
            }
        )
    }

    #[test]
    pub fn test_with_argument() {
        // this is the answer to "PING test"
        let src = ":tmi.twitch.tv PONG tmi.twitch.tv :test";
        let irc_message = IRCMessage::parse(src).unwrap();
        let msg = PongMessage::try_from(irc_message.clone()).unwrap();

        assert_eq!(
            msg,
            PongMessage {
                source: irc_message
            }
        )
    }
}