use serde::{Deserialize, Serialize};
use crate::{field_access, impl_default, impl_display};
#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
pub struct Request {
stream_id: u64,
topic_name: String,
}
impl Request {
pub const fn new() -> Self {
Self {
stream_id: 0,
topic_name: String::new(),
}
}
}
field_access! {
Request {
stream_id: u64,
}
}
field_access! {
Request {
topic_name: cow { str },
}
}
impl_default!(Request);
impl_display!(Request);
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_request() {
let stream_id = 1;
let topic_name = "test topic";
let request = Request::new()
.with_stream_id(stream_id)
.with_topic_name(topic_name);
let request_json = request.to_string();
assert_eq!(serde_json::to_string(&request).unwrap(), request_json);
assert_eq!(
serde_json::from_str::<Request>(&request_json).unwrap(),
request
);
assert_eq!(request.stream_id(), stream_id);
assert_eq!(request.topic_name(), topic_name);
}
}