cassandra_protocol/frame/
message_auth_response.rs

1use crate::error;
2use crate::frame::{Direction, Envelope, Flags, FromCursor, Opcode, Serialize, Version};
3use crate::types::CBytes;
4use derive_more::Constructor;
5use std::io::Cursor;
6
7#[derive(Debug, Constructor, Clone, Ord, PartialOrd, Eq, PartialEq, Hash)]
8pub struct BodyReqAuthResponse {
9    pub data: CBytes,
10}
11
12impl Serialize for BodyReqAuthResponse {
13    #[inline]
14    fn serialize(&self, cursor: &mut Cursor<&mut Vec<u8>>, version: Version) {
15        self.data.serialize(cursor, version);
16    }
17}
18
19impl FromCursor for BodyReqAuthResponse {
20    fn from_cursor(cursor: &mut Cursor<&[u8]>, version: Version) -> error::Result<Self> {
21        CBytes::from_cursor(cursor, version).map(BodyReqAuthResponse::new)
22    }
23}
24
25impl Envelope {
26    /// Creates new envelope of type `AuthResponse`.
27    pub fn new_req_auth_response(token_bytes: CBytes, version: Version) -> Envelope {
28        let direction = Direction::Request;
29        let opcode = Opcode::AuthResponse;
30        let body = BodyReqAuthResponse::new(token_bytes);
31
32        Envelope::new(
33            version,
34            direction,
35            Flags::empty(),
36            opcode,
37            0,
38            body.serialize_to_vec(version),
39            None,
40            vec![],
41        )
42    }
43}
44
45#[cfg(test)]
46mod tests {
47    use super::*;
48    use crate::types::CBytes;
49
50    #[test]
51    fn body_req_auth_response() {
52        let bytes = CBytes::new(vec![1, 2, 3]);
53        let body = BodyReqAuthResponse::new(bytes);
54        assert_eq!(
55            body.serialize_to_vec(Version::V4),
56            vec![0, 0, 0, 3, 1, 2, 3]
57        );
58    }
59
60    #[test]
61    fn frame_body_req_auth_response() {
62        let bytes = vec![1, 2, 3];
63        let frame = Envelope::new_req_auth_response(CBytes::new(bytes), Version::V4);
64
65        assert_eq!(frame.version, Version::V4);
66        assert_eq!(frame.opcode, Opcode::AuthResponse);
67        assert_eq!(frame.body, &[0, 0, 0, 3, 1, 2, 3]);
68        assert_eq!(frame.tracing_id, None);
69        assert!(frame.warnings.is_empty());
70    }
71}
cassandra_protocol/frame/message_auth_response.rs

cassandra_protocol/frame/
message_auth_response.rs
