use super::Status;
use crate::error::cip_error_reply;
use rseip_core::{codec::Encode, Error};
#[derive(Debug, Default, PartialEq, Eq)]
pub struct MessageRequest<P, D> {
pub service_code: u8,
pub path: P,
pub data: D,
}
impl<P, D> MessageRequest<P, D>
where
P: Encode,
D: Encode,
{
#[inline]
pub fn new(service_code: u8, path: P, data: D) -> Self {
Self {
service_code,
path,
data,
}
}
}
#[derive(Debug)]
pub struct MessageReply<D> {
pub reply_service: u8,
pub status: Status,
pub remaining_path_size: Option<u8>,
pub data: D,
}
impl<D> MessageReply<D> {
#[inline]
pub fn new(reply_service: u8, status: Status, data: D) -> Self {
Self {
reply_service,
status,
remaining_path_size: None,
data,
}
}
}
impl<D> MessageReplyInterface for MessageReply<D> {
type Value = D;
#[inline]
fn reply_service(&self) -> u8 {
self.reply_service
}
#[inline]
fn status(&self) -> &Status {
&self.status
}
#[inline]
fn value(&self) -> &Self::Value {
&self.data
}
#[inline]
fn into_value(self) -> Self::Value {
self.data
}
}
pub trait MessageReplyInterface {
type Value;
fn reply_service(&self) -> u8;
fn status(&self) -> &Status;
fn value(&self) -> &Self::Value;
fn into_value(self) -> Self::Value;
#[inline]
fn expect_service<E: Error>(&self, expected_service: u8) -> Result<(), E> {
if self.reply_service() != expected_service {
Err(cip_error_reply(self.reply_service(), expected_service))
} else {
Ok(())
}
}
}