use crate::{errors::NetworkParseError, fsemul::pcfs::errors::PcfsApiError};
use bytes::{BufMut, Bytes, BytesMut};
use std::ffi::CStr;
use valuable::{Fields, NamedField, NamedValues, StructDef, Structable, Valuable, Value, Visit};
#[derive(Clone, Debug, PartialEq, Eq)]
pub struct SataChangeModePacketBody {
path: String,
set_write_mode: bool,
}
impl SataChangeModePacketBody {
pub fn new(path: String, set_write_mode: bool) -> Result<Self, PcfsApiError> {
if path.len() > 511 {
return Err(PcfsApiError::PathTooLong(path));
}
Ok(Self {
path,
set_write_mode,
})
}
#[must_use]
pub fn path(&self) -> &str {
self.path.as_str()
}
pub fn set_path(&mut self, new_path: String) -> Result<(), PcfsApiError> {
if new_path.len() > 511 {
return Err(PcfsApiError::PathTooLong(new_path));
}
self.path = new_path;
Ok(())
}
#[must_use]
pub const fn will_set_write_mode(&self) -> bool {
self.set_write_mode
}
pub const fn set_write_mode(&mut self, will_set: bool) {
self.set_write_mode = will_set;
}
}
impl TryFrom<Bytes> for SataChangeModePacketBody {
type Error = NetworkParseError;
fn try_from(value: Bytes) -> Result<Self, Self::Error> {
if value.len() < 0x204 {
return Err(NetworkParseError::FieldNotLongEnough(
"SataChangeMode",
"Body",
0x204,
value.len(),
value,
));
}
if value.len() > 0x204 {
return Err(NetworkParseError::UnexpectedTrailer(
"SataChangeMode",
value.slice(0x204..),
));
}
let (path_bytes, num) = value.split_at(0x200);
let path_c_str =
CStr::from_bytes_until_nul(path_bytes).map_err(NetworkParseError::BadCString)?;
let write_mode_flags = u32::from_be_bytes([num[0], num[1], num[2], num[3]]);
let final_path = path_c_str.to_str()?.to_owned();
Ok(Self {
path: final_path,
set_write_mode: write_mode_flags & 0x222 != 0,
})
}
}
impl From<&SataChangeModePacketBody> for Bytes {
fn from(value: &SataChangeModePacketBody) -> Self {
let mut result = BytesMut::with_capacity(0x204);
result.extend_from_slice(value.path.as_bytes());
result.extend(BytesMut::zeroed(0x200 - result.len()));
result.put_u32(if value.set_write_mode { 0x666 } else { 0x444 });
result.freeze()
}
}
impl From<SataChangeModePacketBody> for Bytes {
fn from(value: SataChangeModePacketBody) -> Self {
Self::from(&value)
}
}
const SATA_CHANGE_MODE_PACKET_BODY_FIELDS: &[NamedField<'static>] = &[NamedField::new("path")];
impl Structable for SataChangeModePacketBody {
fn definition(&self) -> StructDef<'_> {
StructDef::new_static(
"SataChangeModePacketBody",
Fields::Named(SATA_CHANGE_MODE_PACKET_BODY_FIELDS),
)
}
}
impl Valuable for SataChangeModePacketBody {
fn as_value(&self) -> Value<'_> {
Value::Structable(self)
}
fn visit(&self, visitor: &mut dyn Visit) {
visitor.visit_named_fields(&NamedValues::new(
SATA_CHANGE_MODE_PACKET_BODY_FIELDS,
&[Valuable::as_value(&self.path)],
));
}
}