krabka_protocol/opt/rustwide/workdir/generated/
UserScramCredentialRecord.owned.rs

1// AUTO-GENERATED by krabka-protocol-codegen against a9ce3221537b8653448750697915607dc7936cf3. Do not edit.
2
3use bytes::{Buf, BufMut};
4
5use crate::{
6    Decode, Encode, ProtocolError, UnknownTaggedFields,
7    primitives::{
8        fixed::{get_i8, get_i32, put_i8, put_i32},
9        string_bytes::{
10            bytes_len, compact_bytes_len, compact_string_len, get_bytes_owned,
11            get_compact_bytes_owned, get_compact_string_owned, get_string_owned, put_bytes,
12            put_compact_bytes, put_compact_string, put_string, string_len,
13        },
14    },
15    tagged_fields::{WriteTaggedFields, read_tagged_fields, tagged_fields_len},
16};
17pub const MIN_VERSION: i16 = 0;
18pub const MAX_VERSION: i16 = 0;
19pub const FLEXIBLE_MIN: i16 = 0;
20#[inline]
21#[must_use]
22pub fn is_flexible(version: i16) -> bool {
23    version >= FLEXIBLE_MIN
24}
25#[derive(Debug, Clone, PartialEq, Eq, Default)]
26pub struct UserScramCredentialRecord {
27    pub name: String,
28    pub mechanism: i8,
29    pub salt: ::bytes::Bytes,
30    pub stored_key: ::bytes::Bytes,
31    pub server_key: ::bytes::Bytes,
32    pub iterations: i32,
33    pub unknown_tagged_fields: UnknownTaggedFields,
34}
35impl Encode for UserScramCredentialRecord {
36    fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> Result<(), ProtocolError> {
37        if !(MIN_VERSION..=MAX_VERSION).contains(&version) {
38            return Err(ProtocolError::SchemaMismatch(
39                "UserScramCredentialRecord version out of range",
40            ));
41        }
42        let flex = is_flexible(version);
43        if version >= 0 {
44            if flex {
45                let () = put_compact_string(buf, &self.name);
46            } else {
47                let () = put_string(buf, &self.name);
48            }
49        }
50        if version >= 0 {
51            put_i8(buf, self.mechanism);
52        }
53        if version >= 0 {
54            if flex {
55                let () = put_compact_bytes(buf, &self.salt);
56            } else {
57                let () = put_bytes(buf, &self.salt);
58            }
59        }
60        if version >= 0 {
61            if flex {
62                let () = put_compact_bytes(buf, &self.stored_key);
63            } else {
64                let () = put_bytes(buf, &self.stored_key);
65            }
66        }
67        if version >= 0 {
68            if flex {
69                let () = put_compact_bytes(buf, &self.server_key);
70            } else {
71                let () = put_bytes(buf, &self.server_key);
72            }
73        }
74        if version >= 0 {
75            put_i32(buf, self.iterations);
76        }
77        if flex {
78            let tagged = WriteTaggedFields::new();
79            tagged.write(buf, &self.unknown_tagged_fields);
80        }
81        Ok(())
82    }
83    fn encoded_len(&self, version: i16) -> usize {
84        let flex = is_flexible(version);
85        let mut n: usize = 0;
86        if version >= 0 {
87            n += if flex {
88                compact_string_len(&self.name)
89            } else {
90                string_len(&self.name)
91            };
92        }
93        if version >= 0 {
94            n += 1;
95        }
96        if version >= 0 {
97            n += if flex {
98                compact_bytes_len(&self.salt)
99            } else {
100                bytes_len(&self.salt)
101            };
102        }
103        if version >= 0 {
104            n += if flex {
105                compact_bytes_len(&self.stored_key)
106            } else {
107                bytes_len(&self.stored_key)
108            };
109        }
110        if version >= 0 {
111            n += if flex {
112                compact_bytes_len(&self.server_key)
113            } else {
114                bytes_len(&self.server_key)
115            };
116        }
117        if version >= 0 {
118            n += 4;
119        }
120        if flex {
121            let known_pairs: Vec<(u32, usize)> = Vec::new();
122            n += tagged_fields_len(&known_pairs, &self.unknown_tagged_fields);
123        }
124        n
125    }
126}
127impl Decode<'_> for UserScramCredentialRecord {
128    fn decode<B: Buf>(buf: &mut B, version: i16) -> Result<Self, ProtocolError> {
129        if !(MIN_VERSION..=MAX_VERSION).contains(&version) {
130            return Err(ProtocolError::SchemaMismatch(
131                "UserScramCredentialRecord version out of range",
132            ));
133        }
134        let flex = is_flexible(version);
135        let mut out = Self::default();
136        if version >= 0 {
137            out.name = if flex {
138                get_compact_string_owned(buf)?
139            } else {
140                get_string_owned(buf)?
141            };
142        }
143        if version >= 0 {
144            out.mechanism = get_i8(buf)?;
145        }
146        if version >= 0 {
147            out.salt = if flex {
148                get_compact_bytes_owned(buf)?
149            } else {
150                get_bytes_owned(buf)?
151            };
152        }
153        if version >= 0 {
154            out.stored_key = if flex {
155                get_compact_bytes_owned(buf)?
156            } else {
157                get_bytes_owned(buf)?
158            };
159        }
160        if version >= 0 {
161            out.server_key = if flex {
162                get_compact_bytes_owned(buf)?
163            } else {
164                get_bytes_owned(buf)?
165            };
166        }
167        if version >= 0 {
168            out.iterations = get_i32(buf)?;
169        }
170        if flex {
171            out.unknown_tagged_fields = read_tagged_fields(buf, |_tag, _payload| Ok(false))?;
172        }
173        Ok(out)
174    }
175}
176#[cfg(test)]
177impl UserScramCredentialRecord {
178    #[must_use]
179    pub fn populated(version: i16) -> Self {
180        let mut m = Self::default();
181        if version >= 0 {
182            m.name = "x".to_string();
183        }
184        if version >= 0 {
185            m.mechanism = 1i8;
186        }
187        if version >= 0 {
188            m.salt = ::bytes::Bytes::from_static(b"x");
189        }
190        if version >= 0 {
191            m.stored_key = ::bytes::Bytes::from_static(b"x");
192        }
193        if version >= 0 {
194            m.server_key = ::bytes::Bytes::from_static(b"x");
195        }
196        if version >= 0 {
197            m.iterations = 1i32;
198        }
199        m
200    }
201}
202/// Default JSON payload matching `Self::default()` for JVM oracle differential testing.
203/// Only includes fields valid for the given version.
204#[must_use]
205#[allow(unused_comparisons)]
206pub fn default_json(_version: i16) -> ::serde_json::Value {
207    let mut obj = ::serde_json::Map::new();
208    obj.insert(
209        "name".to_string(),
210        ::serde_json::Value::String(String::new()),
211    );
212    obj.insert("mechanism".to_string(), ::serde_json::json!(0));
213    obj.insert(
214        "salt".to_string(),
215        ::serde_json::Value::String(String::new()),
216    );
217    obj.insert(
218        "storedKey".to_string(),
219        ::serde_json::Value::String(String::new()),
220    );
221    obj.insert(
222        "serverKey".to_string(),
223        ::serde_json::Value::String(String::new()),
224    );
225    obj.insert("iterations".to_string(), ::serde_json::json!(0));
226    ::serde_json::Value::Object(obj)
227}
krabka_protocol/opt/rustwide/workdir/generated/UserScramCredentialRecord.owned.rs

krabka_protocol/opt/rustwide/workdir/generated/
UserScramCredentialRecord.owned.rs
