{"},{"Add":" Disconnected,"},{"Add":" Resetting(P),"},{"Add":" Connected(P),"},{"Add":"}"},{"Add":""},{"Add":"enum ReadError {"},{"Add":" TimeoutOrBadFrame,"},{"Add":" DeviceReset,"},{"Add":"}"},{"Add":""},{"Add":"impl From for ReadError {"},{"Add":" fn from(e: DriverError) -> Self {"},{"Add":" match e {"},{"Add":" DriverError::DeviceReset => Self::DeviceReset,"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[derive(IntoPrimitive, TryFromPrimitive, Debug, Clone, Copy, Eq, PartialEq, Hash)]"},{"Add":"#[repr(u8)]"},{"Add":"enum FrameType {"},{"Add":" Ack = 0x06,"},{"Add":" Nak = 0x15,"},{"Add":" Sof = 0x01,"},{"Add":" Can = 0x18,"},{"Add":"}"},{"Add":""},{"Add":"#[derive(IntoPrimitive, TryFromPrimitive, Debug, Clone, Copy, Eq, PartialEq, Hash)]"},{"Add":"#[repr(u8)]"},{"Add":"enum DataFrameType {"},{"Add":" Req = 0x00,"},{"Add":" Res = 0x01,"},{"Add":"}"},{"Add":""},{"Add":"pub struct SerialDriver

Result>>"},{"Add":"where"},{"Add":" P: SerialPort,"},{"Add":" F: FnMut() -> Result,"},{"Add":"{"},{"Add":" open_port: F,"},{"Add":" serial_port: PortState

,"},{"Add":" buffer: IOBuffer,"},{"Add":"}"},{"Add":""},{"Add":"impl SerialDriver"},{"Add":"where"},{"Add":" P: SerialPort,"},{"Add":" F: FnMut() -> Result,"},{"Add":"{"},{"Add":" #[instrument(skip(self))]"},{"Add":" fn reset_port(&mut self) {"},{"Add":" trace!(\"closing port\");"},{"Add":" match self.serial_port {"},{"Add":" PortState::Resetting(_) => {}"},{"Add":" _ => self.serial_port = PortState::Disconnected,"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" #[instrument(skip(self, f))]"},{"Add":" fn use_port(&mut self, f: impl FnOnce(&mut IOBuffer, &mut P) -> T) -> T {"},{"Add":" match self.serial_port {"},{"Add":" PortState::Disconnected => {}"},{"Add":" PortState::Resetting(ref mut port) => return f(&mut self.buffer, port),"},{"Add":" PortState::Connected(ref mut port) => return f(&mut self.buffer, port),"},{"Add":" }"},{"Add":""},{"Add":" trace!(\"port is closed, connecting...\");"},{"Add":" 'reconnect: loop {"},{"Add":" self.serial_port = PortState::Disconnected;"},{"Add":""},{"Add":" match (&mut self.open_port)() {"},{"Add":" Ok(mut port) => {"},{"Add":" port.clear(serialport::ClearBuffer::All);"},{"Add":" if port.write_all(&[FrameType::Nak.into()]).is_err() {"},{"Add":" continue 'reconnect;"},{"Add":" }"},{"Add":""},{"Add":" self.serial_port = PortState::Resetting(port);"},{"Add":" match (SoftResetSequence {}.execute(self)) {"},{"Add":" Ok(_) => {}"},{"Add":" Err(e) => {"},{"Add":" debug!(\"failed to execute connect command: {:?}\", e);"},{"Add":" continue 'reconnect;"},{"Add":" }"},{"Add":" }"},{"Add":" match std::mem::replace(&mut self.serial_port, PortState::Disconnected) {"},{"Add":" PortState::Connected(_) => {"},{"Add":" unreachable!(\"a port shouldn't transition to connected during reset\")"},{"Add":" }"},{"Add":" PortState::Resetting(port) => {"},{"Add":" trace!(\"connected to serial port\");"},{"Add":" self.serial_port = PortState::Connected(port);"},{"Add":" }"},{"Add":" PortState::Disconnected => continue 'reconnect,"},{"Add":" }"},{"Add":" match self.serial_port {"},{"Add":" PortState::Connected(ref mut port) => return f(&mut self.buffer, port),"},{"Add":" _ => unreachable!(),"},{"Add":" }"},{"Add":" }"},{"Add":" Err(e) => {"},{"Add":" std::thread::sleep(SOFT_RESET_DELAY);"},{"Add":" // FIXME: Backoff"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" fn write_one(&mut self, byte: impl Into) -> Result<(), DriverError> {"},{"Add":" self.write_all(&[byte.into()])"},{"Add":" }"},{"Add":""},{"Add":" #[instrument(skip(self, data))]"},{"Add":" fn write_all(&mut self, data: impl AsRef<[u8]>) -> Result<(), DriverError> {"},{"Add":" match self.use_port(|_, f| f.write_all(data.as_ref())) {"},{"Add":" Err(_) => Err(DriverError::DeviceReset),"},{"Add":" Ok(_) => Ok(()),"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" #[instrument(skip(self, length, timeout))]"},{"Add":" fn read_at_least(&mut self, length: usize, timeout: Timeout) -> Result<(), ReadError> {"},{"Add":" self.use_port(|b, p| {"},{"Add":" while b.available() < length {"},{"Add":" b.append(length - b.available(), |b| match p.read(b) {"},{"Add":" Err(e) if e.kind() == std::io::ErrorKind::TimedOut => {"},{"Add":" if timeout.is_expired() {"},{"Add":" (0, Err(ReadError::TimeoutOrBadFrame))"},{"Add":" } else {"},{"Add":" (0, Ok(()))"},{"Add":" }"},{"Add":" }"},{"Add":" Ok(0) | Err(_) => (0, Err(ReadError::DeviceReset)),"},{"Add":" Ok(l) => (l, Ok(())),"},{"Add":" })?;"},{"Add":" }"},{"Add":" Ok(())"},{"Add":" })"},{"Add":" }"},{"Add":""},{"Add":" #[instrument(skip(self, timeout))]"},{"Add":" fn receive_frame(&mut self, timeout: Timeout) -> Result, ReadError> {"},{"Add":" loop {"},{"Add":" self.read_at_least(1, timeout)?;"},{"Add":" let typ = self.buffer.consume(1)[0];"},{"Add":" match typ.try_into() {"},{"Add":" Ok(FrameType::Sof) => {}"},{"Add":" _ => continue,"},{"Add":" }"},{"Add":""},{"Add":" trace!(\"received start of frame\");"},{"Add":" match self.read_data_frame(Timeout::new(READ_TIMEOUT)) {"},{"Add":" Ok(r) => return Ok(r),"},{"Add":" Err(ReadError::TimeoutOrBadFrame) => {}"},{"Add":" _ => return Err(ReadError::DeviceReset),"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" #[instrument(skip(self, timeout))]"},{"Add":" fn read_data_frame(&mut self, timeout: Timeout) -> Result, ReadError> {"},{"Add":" self.read_at_least(1, timeout)?;"},{"Add":" let len = self.buffer.consume(1)[0];"},{"Add":""},{"Add":" trace!(\"expecting a frame of {} bytes\", len);"},{"Add":""},{"Add":" let count = (len) as usize;"},{"Add":" self.read_at_least(count, timeout)?;"},{"Add":" let payload = self.buffer.consume(count);"},{"Add":""},{"Add":" let (data, actual_checksum) = payload.split_at(count - 1);"},{"Add":""},{"Add":" let expected_checksum = data.iter().fold(0xff ^ len, |a, b| a ^ b);"},{"Add":" if actual_checksum[0] != expected_checksum {"},{"Add":" debug!("},{"Add":" \"received a frame with an invalid checksum: {} != {}\","},{"Add":" actual_checksum[0], expected_checksum"},{"Add":" );"},{"Add":" drop(payload);"},{"Add":" debug!(\"sending nak\");"},{"Add":" self.write_one(FrameType::Nak)?;"},{"Add":" return Err(ReadError::TimeoutOrBadFrame);"},{"Add":" }"},{"Add":""},{"Add":" let raw_command = RawCommandData::new(data[1], &data[2..]);"},{"Add":" let command = match raw_command.try_into() {"},{"Add":" Err(e) => {"},{"Add":" debug!(\"received a frame with invalid data: {:?}\", e);"},{"Add":" drop(payload);"},{"Add":" self.write_one(FrameType::Nak)?;"},{"Add":" return Err(ReadError::TimeoutOrBadFrame);"},{"Add":" }"},{"Add":" Ok(v) => match data[0] {"},{"Add":" 0x00 => Frame::Request(v),"},{"Add":" 0x01 => Frame::Response(v),"},{"Add":" v => {"},{"Add":" debug!(\"received a frame with invalid type: {:02x}\", v);"},{"Add":" drop(payload);"},{"Add":" self.write_one(FrameType::Nak)?;"},{"Add":" return Err(ReadError::TimeoutOrBadFrame);"},{"Add":" }"},{"Add":" },"},{"Add":" };"},{"Add":""},{"Add":" Ok(command)"},{"Add":" }"},{"Add":""},{"Add":" #[instrument(skip(self, frame_type, command))]"},{"Add":" fn write_data_frame("},{"Add":" &mut self,"},{"Add":" frame_type: DataFrameType,"},{"Add":" command: RawCommandData,"},{"Add":" ) -> Result<(), DriverError> {"},{"Add":" let len = command.parameters().len() as u8 + 3;"},{"Add":" let mut frame_data = Vec::with_capacity(len as usize);"},{"Add":""},{"Add":" let data_frame_type = frame_type.into();"},{"Add":" frame_data.push(FrameType::Sof.into());"},{"Add":" frame_data.push(len);"},{"Add":" frame_data.push(data_frame_type);"},{"Add":" frame_data.push(command.command_id());"},{"Add":" frame_data.extend_from_slice(command.parameters());"},{"Add":" let checksum = command.parameters().iter().fold("},{"Add":" 0xff ^ len ^ data_frame_type ^ command.command_id(),"},{"Add":" |a, b| a ^ b,"},{"Add":" );"},{"Add":" frame_data.push(checksum);"},{"Add":""},{"Add":" for retry in 0..3 {"},{"Add":" self.write_all(&frame_data)?;"},{"Add":" let timeout = Timeout::new(ACK_TIMEOUT);"},{"Add":" match self.read_at_least(1, timeout) {"},{"Add":" Err(ReadError::DeviceReset) => return Err(DriverError::DeviceReset),"},{"Add":" Ok(_) => {}"},{"Add":" _ => continue,"},{"Add":" }"},{"Add":""},{"Add":" let frame_type = self.buffer.consume(1)[0]"},{"Add":" .try_into()"},{"Add":" .unwrap_or(FrameType::Nak);"},{"Add":" trace!(\"received a {:?} frame\", frame_type);"},{"Add":" match frame_type {"},{"Add":" FrameType::Sof => {"},{"Add":" debug!(\"received a Sof when expecting an ack\");"},{"Add":" match self.write_one(FrameType::Can) {"},{"Add":" Ok(_) => {}"},{"Add":" Err(_) => return Err(DriverError::DeviceReset),"},{"Add":" }"},{"Add":" }"},{"Add":" FrameType::Ack => return Ok(()),"},{"Add":" FrameType::Can | FrameType::Nak => {}"},{"Add":" };"},{"Add":" let elapsed = timeout"},{"Add":" .remaining()"},{"Add":" .expect(\"this was explicitly set to a finite timeout\")"},{"Add":" .min(ACK_TIMEOUT);"},{"Add":" let duration_to_wait ="},{"Add":" (BACKOFF_TIME_BASE + BACKOFF_TIME_FACTOR * retry).saturating_sub(elapsed);"},{"Add":" trace!(\"waiting for {:?} before retrying send\", &duration_to_wait);"},{"Add":" std::thread::sleep(duration_to_wait);"},{"Add":" }"},{"Add":""},{"Add":" Err(DriverError::DeviceReset)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl CommandSequenceContext for SerialDriver"},{"Add":"where"},{"Add":" P: SerialPort,"},{"Add":" F: FnMut() -> Result,"},{"Add":"{"},{"Add":" fn send(&mut self, command: crate::commands::Frame) -> Result<(), CommandSequenceError>"},{"Add":" where"},{"Add":" T: Into,"},{"Add":" {"},{"Add":" match command {"},{"Add":" Frame::Request(command) => self"},{"Add":" .write_data_frame(DataFrameType::Req, command.into())"},{"Add":" .map_err(Into::into),"},{"Add":" Frame::Response(command) => self"},{"Add":" .write_data_frame(DataFrameType::Res, command.into())"},{"Add":" .map_err(Into::into),"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl Driver for SerialDriver"},{"Add":"where"},{"Add":" P: SerialPort,"},{"Add":" F: FnMut() -> Result,"},{"Add":"{"},{"Add":" fn connect(&mut self) {"},{"Add":" self.use_port(|_, _| ())"},{"Add":" }"},{"Add":""},{"Add":" fn read_frame(&mut self) -> Result, FrameReadError> {"},{"Add":" loop {"},{"Add":" match self.receive_frame(Timeout::new(READ_TIMEOUT)) {"},{"Add":" Ok(f) => return Ok(f),"},{"Add":" Err(ReadError::TimeoutOrBadFrame) => return Err(FrameReadError::Timeout),"},{"Add":" _ => self.reset_port(),"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" #[instrument(skip(self, command))]"},{"Add":" fn execute_command(&mut self, mut command: impl CommandSequence) {"},{"Add":" loop {"},{"Add":" match command.execute(self) {"},{"Add":" Err(CommandSequenceError::Cancel) => break,"},{"Add":" Err(_) => {}"},{"Add":" Ok(_) => break,"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"serial_driver","metadata":576},"context":[{"change":0,"pos":6134}],"contents":[]}},{"FileAdd":{"meta":{"basename":"test.rs","metadata":0},"context":[{"change":0,"pos":17073}],"contents":[{"Add":"use mockall::{mock, Sequence};"},{"Add":"use std::{"},{"Add":" io::{Read, Write},"},{"Add":" marker::PhantomData,"},{"Add":" ops::{Deref, DerefMut},"},{"Add":"};"},{"Add":""},{"Add":"use serialport::SerialPort;"},{"Add":""},{"Add":"use super::PortState;"},{"Add":"use crate::driver::{"},{"Add":" serial::{io_buffer::IOBuffer, serial_driver::FrameType},"},{"Add":" Driver,"},{"Add":"};"},{"Add":""},{"Add":"type SerialDriver<'a> ="},{"Add":" super::SerialDriver Result + 'a>>;"},{"Add":""},{"Add":"mock!("},{"Add":" pub(crate) Port {}"},{"Add":""},{"Add":" impl Write for Port {"},{"Add":" fn write(&mut self, buf: &[u8]) -> std::io::Result;"},{"Add":" fn flush(&mut self) -> std::io::Result<()>;"},{"Add":" }"},{"Add":""},{"Add":" impl Read for Port {"},{"Add":" fn read(&mut self, buf: &mut [u8]) -> std::io::Result;"},{"Add":" }"},{"Add":""},{"Add":" impl SerialPort for Port {"},{"Add":" fn name(&self) -> Option;"},{"Add":" fn baud_rate(&self) -> serialport::Result;"},{"Add":" fn data_bits(&self) -> serialport::Result;"},{"Add":" fn flow_control(&self) -> serialport::Result;"},{"Add":" fn parity(&self) -> serialport::Result;"},{"Add":" fn stop_bits(&self) -> serialport::Result;"},{"Add":" fn timeout(&self) -> std::time::Duration;"},{"Add":" fn set_baud_rate(&mut self, baud_rate: u32) -> serialport::Result<()>;"},{"Add":" fn set_data_bits(&mut self, data_bits: serialport::DataBits) -> serialport::Result<()>;"},{"Add":" fn set_flow_control(&mut self, flow_control: serialport::FlowControl) -> serialport::Result<()>;"},{"Add":" fn set_parity(&mut self, parity: serialport::Parity) -> serialport::Result<()>;"},{"Add":" fn set_stop_bits(&mut self, stop_bits: serialport::StopBits) -> serialport::Result<()>;"},{"Add":" fn set_timeout(&mut self, timeout: std::time::Duration) -> serialport::Result<()>;"},{"Add":" fn write_request_to_send(&mut self, level: bool) -> serialport::Result<()>;"},{"Add":" fn write_data_terminal_ready(&mut self, level: bool) -> serialport::Result<()>;"},{"Add":" fn read_clear_to_send(&mut self) -> serialport::Result;"},{"Add":" fn read_data_set_ready(&mut self) -> serialport::Result;"},{"Add":" fn read_ring_indicator(&mut self) -> serialport::Result;"},{"Add":" fn read_carrier_detect(&mut self) -> serialport::Result;"},{"Add":" fn bytes_to_read(&self) -> serialport::Result;"},{"Add":" fn bytes_to_write(&self) -> serialport::Result;"},{"Add":" fn clear(&self, buffer_to_clear: serialport::ClearBuffer) -> serialport::Result<()>;"},{"Add":" fn try_clone(&self) -> serialport::Result>;"},{"Add":" fn set_break(&self) -> serialport::Result<()>;"},{"Add":" fn clear_break(&self) -> serialport::Result<()>;"},{"Add":" }"},{"Add":");"},{"Add":""},{"Add":"impl Drop for MockPort {"},{"Add":" fn drop(&mut self) {"},{"Add":" self.checkpoint()"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"fn create_driver<'a>(f: impl FnMut() -> Result + 'a) -> SerialDriver<'a> {"},{"Add":" SerialDriver {"},{"Add":" buffer: IOBuffer::new(),"},{"Add":" serial_port: PortState::Disconnected,"},{"Add":" open_port: Box::new(f),"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"fn driver_checkpoint<'a>(d: &mut SerialDriver<'a>) {"},{"Add":" match &mut d.serial_port {"},{"Add":" PortState::Connected(p) | PortState::Resetting(p) => p.checkpoint(),"},{"Add":" _ => panic!(\"expected a state with an active port\"),"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[test]"},{"Add":"fn serial_driver_reconnect() {"},{"Add":" let mut foo = 1;"},{"Add":" let mut factory = || {"},{"Add":" foo += 1;"},{"Add":" if foo < 3 {"},{"Add":" return Err(());"},{"Add":" }"},{"Add":""},{"Add":" let mut port = MockPort::new();"},{"Add":" port"},{"Add":" .expect_clear()"},{"Add":" .returning(|_| serialport::Result::Ok(()));"},{"Add":" port"},{"Add":" .expect_write()"},{"Add":" .returning(|b| std::io::Result::Ok(b.len()));"},{"Add":" port.expect_read().return_once(|b| {"},{"Add":" b[0] = FrameType::Ack.into();"},{"Add":" std::io::Result::Ok(1)"},{"Add":" });"},{"Add":""},{"Add":" Ok(port)"},{"Add":" };"},{"Add":" let mut driver = create_driver(&mut factory);"},{"Add":""},{"Add":" driver.connect();"},{"Add":" drop(driver);"},{"Add":""},{"Add":" assert_eq!(foo, 3);"},{"Add":"}"},{"Add":""},{"Add":"#[test]"},{"Add":"fn serial_driver_reconnect_with_nak() {"},{"Add":" let mut factory = || {"},{"Add":" let mut seq = Sequence::new();"},{"Add":""},{"Add":" let mut port = MockPort::new();"},{"Add":" port"},{"Add":" .expect_clear()"},{"Add":" .returning(|_| serialport::Result::Ok(()));"},{"Add":" port"},{"Add":" .expect_write()"},{"Add":" .returning(|b| std::io::Result::Ok(b.len()));"},{"Add":" port"},{"Add":" .expect_read()"},{"Add":" .times(1)"},{"Add":" .in_sequence(&mut seq)"},{"Add":" .return_once(|b| {"},{"Add":" b[0] = FrameType::Nak.into();"},{"Add":" std::io::Result::Ok(1)"},{"Add":" });"},{"Add":" port"},{"Add":" .expect_read()"},{"Add":" .times(1)"},{"Add":" .in_sequence(&mut seq)"},{"Add":" .return_once(|b| {"},{"Add":" b[0] = FrameType::Ack.into();"},{"Add":" std::io::Result::Ok(1)"},{"Add":" });"},{"Add":""},{"Add":" Ok(port)"},{"Add":" };"},{"Add":" let mut driver = create_driver(&mut factory);"},{"Add":""},{"Add":" driver.connect();"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"io_buffer.rs","metadata":0},"context":[{"change":0,"pos":6134}],"contents":[{"Add":"use std::{fmt::Debug, ops::Deref};"},{"Add":""},{"Add":"const BUFFER_SIZE: usize = 4096;"},{"Add":""},{"Add":"pub struct IOBuffer {"},{"Add":" buffer: Box<[u8; BUFFER_SIZE]>,"},{"Add":" read_offset: u16,"},{"Add":" write_offset: u16,"},{"Add":"}"},{"Add":""},{"Add":"impl Debug for IOBuffer {"},{"Add":" fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {"},{"Add":" f.debug_struct(\"IOBuffer\")"},{"Add":" .field("},{"Add":" \"available\","},{"Add":" &&self.buffer[(self.read_offset as usize)..(self.write_offset as usize)],"},{"Add":" )"},{"Add":" .field("},{"Add":" \"remaining_capacity\","},{"Add":" &(BUFFER_SIZE as u16 - self.write_offset),"},{"Add":" )"},{"Add":" .finish()"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl IOBuffer {"},{"Add":" pub fn new() -> Self {"},{"Add":" Self {"},{"Add":" buffer: Box::new([0u8; BUFFER_SIZE]),"},{"Add":" read_offset: 0,"},{"Add":" write_offset: 0,"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" pub fn consume<'a>(&'a mut self, length: usize) -> ConsumingIOBuffer<'a> {"},{"Add":" assert!("},{"Add":" length <= self.available(),"},{"Add":" \"cannot consume more data than is contained in the buffer\""},{"Add":" );"},{"Add":" ConsumingIOBuffer {"},{"Add":" target: self,"},{"Add":" take: length as u16,"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" pub fn append("},{"Add":" &mut self,"},{"Add":" length_estimate: usize,"},{"Add":" f: impl FnOnce(&mut [u8]) -> (usize, T),"},{"Add":" ) -> T {"},{"Add":" if self.write_offset as usize + length_estimate > BUFFER_SIZE {"},{"Add":" self"},{"Add":" .buffer"},{"Add":" .copy_within((self.read_offset as usize)..(self.write_offset as usize), 0);"},{"Add":" self.write_offset -= self.read_offset;"},{"Add":" self.read_offset = 0;"},{"Add":" }"},{"Add":""},{"Add":" assert!("},{"Add":" self.write_offset as usize + length_estimate <= BUFFER_SIZE,"},{"Add":" \"the buffer does not have enough room for the requested length estimate\""},{"Add":" );"},{"Add":" let (append, result) = f(&mut self.buffer[(self.write_offset as usize)..]);"},{"Add":" assert!("},{"Add":" self.write_offset as usize + append <= BUFFER_SIZE,"},{"Add":" \"the function wrote more bytes than available in the buffer\""},{"Add":" );"},{"Add":" self.write_offset += append as u16;"},{"Add":" result"},{"Add":" }"},{"Add":""},{"Add":" pub fn available(&self) -> usize {"},{"Add":" (self.write_offset - self.read_offset) as usize"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct ConsumingIOBuffer<'a> {"},{"Add":" target: &'a mut IOBuffer,"},{"Add":" take: u16,"},{"Add":"}"},{"Add":""},{"Add":"impl<'a> Debug for ConsumingIOBuffer<'a> {"},{"Add":" fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {"},{"Add":" f.debug_struct(\"ConsumingIOBuffer\")"},{"Add":" .field(\"target\", &self.target)"},{"Add":" .field(\"take\", &self.take)"},{"Add":" .finish()"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl<'a> Drop for ConsumingIOBuffer<'a> {"},{"Add":" fn drop(&mut self) {"},{"Add":" self.target.read_offset += self.take;"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl<'a> Deref for ConsumingIOBuffer<'a> {"},{"Add":" type Target = [u8];"},{"Add":""},{"Add":" fn deref(&self) -> &Self::Target {"},{"Add":" let start = self.target.read_offset as usize;"},{"Add":" let end = start + self.take as usize;"},{"Add":" &self.target.buffer[start..end]"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[cfg(test)]"},{"Add":"mod test {"},{"Add":" use super::*;"},{"Add":""},{"Add":" #[test]"},{"Add":" #[should_panic(expected = \"cannot consume more data than is contained in the buffer\")]"},{"Add":" fn io_buffer_consume_too_much() {"},{"Add":" let mut sut = IOBuffer::new();"},{"Add":" sut.append(5, |f| {"},{"Add":" f[..5].copy_from_slice(&[1, 2, 3, 4, 5]);"},{"Add":" (5, ())"},{"Add":" });"},{"Add":" sut.consume(6);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" #[should_panic("},{"Add":" expected = \"the buffer does not have enough room for the requested length estimate\""},{"Add":" )]"},{"Add":" fn io_buffer_append_too_much() {"},{"Add":" let mut sut = IOBuffer::new();"},{"Add":" sut.append(BUFFER_SIZE + 1, |f| (5, ()));"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" #[should_panic(expected = \"the function wrote more bytes than available in the buffer\")]"},{"Add":" fn io_buffer_write_too_much() {"},{"Add":" let mut sut = IOBuffer::new();"},{"Add":" sut.append(1, |f| (BUFFER_SIZE + 1, ()));"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn io_buffer_append() {"},{"Add":" let mut sut = IOBuffer::new();"},{"Add":" sut.append(5, |f| {"},{"Add":" f[..5].copy_from_slice(&[1, 2, 3, 4, 5]);"},{"Add":" (5, ())"},{"Add":" });"},{"Add":" assert_eq!(sut.available(), 5);"},{"Add":" let cons = sut.consume(5);"},{"Add":" assert_eq!(cons.deref(), &[1, 2, 3, 4, 5]);"},{"Add":" drop(cons);"},{"Add":" assert_eq!(sut.available(), 0);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn io_write_read_write_read() {"},{"Add":" let mut sut = IOBuffer::new();"},{"Add":" sut.append(5, |f| {"},{"Add":" f[..5].copy_from_slice(&[1, 2, 3, 4, 5]);"},{"Add":" (5, ())"},{"Add":" });"},{"Add":" assert_eq!(sut.available(), 5);"},{"Add":" let cons = sut.consume(5);"},{"Add":" assert_eq!(cons.deref(), &[1, 2, 3, 4, 5]);"},{"Add":" drop(cons);"},{"Add":""},{"Add":" sut.append(5, |f| {"},{"Add":" f[..5].copy_from_slice(&[6, 7, 8, 9, 10]);"},{"Add":" (5, ())"},{"Add":" });"},{"Add":" assert_eq!(sut.available(), 5);"},{"Add":" let cons = sut.consume(5);"},{"Add":" assert_eq!(cons.deref(), &[6, 7, 8, 9, 10]);"},{"Add":" drop(cons);"},{"Add":" assert_eq!(sut.available(), 0);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn io_write_write_read_read() {"},{"Add":" let mut sut = IOBuffer::new();"},{"Add":" sut.append(5, |f| {"},{"Add":" f[..6].copy_from_slice(&[1, 2, 3, 4, 5, 6]);"},{"Add":" (6, ())"},{"Add":" });"},{"Add":" assert_eq!(sut.available(), 6);"},{"Add":""},{"Add":" sut.append(5, |f| {"},{"Add":" f[..4].copy_from_slice(&[7, 8, 9, 10]);"},{"Add":" (4, ())"},{"Add":" });"},{"Add":" assert_eq!(sut.available(), 10);"},{"Add":""},{"Add":" let cons = sut.consume(3);"},{"Add":" assert_eq!(cons.deref(), &[1, 2, 3]);"},{"Add":" drop(cons);"},{"Add":" assert_eq!(sut.available(), 7);"},{"Add":""},{"Add":" let cons = sut.consume(7);"},{"Add":" assert_eq!(cons.deref(), &[4, 5, 6, 7, 8, 9, 10]);"},{"Add":" drop(cons);"},{"Add":" assert_eq!(sut.available(), 0);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn io_write_read_many() {"},{"Add":" for _ in 0..1000 {"},{"Add":" let mut sut = IOBuffer::new();"},{"Add":" sut.append(5, |f| {"},{"Add":" f[..6].copy_from_slice(&[1, 2, 3, 4, 5, 6]);"},{"Add":" (6, ())"},{"Add":" });"},{"Add":" assert_eq!(sut.available(), 6);"},{"Add":""},{"Add":" sut.append(5, |f| {"},{"Add":" f[..4].copy_from_slice(&[7, 8, 9, 10]);"},{"Add":" (4, ())"},{"Add":" });"},{"Add":" assert_eq!(sut.available(), 10);"},{"Add":""},{"Add":" let cons = sut.consume(3);"},{"Add":" assert_eq!(cons.deref(), &[1, 2, 3]);"},{"Add":" drop(cons);"},{"Add":" assert_eq!(sut.available(), 7);"},{"Add":""},{"Add":" let cons = sut.consume(7);"},{"Add":" assert_eq!(cons.deref(), &[4, 5, 6, 7, 8, 9, 10]);"},{"Add":" drop(cons);"},{"Add":" assert_eq!(sut.available(), 0);"},{"Add":" }"},{"Add":" }"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"commands.rs","metadata":0},"context":[{"change":0,"pos":361}],"contents":[{"Add":"use num_enum::{Default, IntoPrimitive, TryFromPrimitive};"},{"Add":""},{"Add":"#[derive(Debug, Clone)]"},{"Add":"pub enum Frame {"},{"Add":" Request(T),"},{"Add":" Response(T),"},{"Add":"}"},{"Add":""},{"Add":"#[derive(Debug, Clone)]"},{"Add":"pub struct RawCommandData {"},{"Add":" command_id: u8,"},{"Add":" parameters: Vec,"},{"Add":"}"},{"Add":""},{"Add":"impl RawCommandData {"},{"Add":" pub fn new(command_id: u8, parameters: impl AsRef<[u8]>) -> Self {"},{"Add":" Self {"},{"Add":" command_id,"},{"Add":" parameters: parameters.as_ref().to_vec(),"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl Default for RawCommandData {"},{"Add":" fn default() -> Self {"},{"Add":" Self {"},{"Add":" command_id: Default::default(),"},{"Add":" parameters: Default::default(),"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl RawCommandData {"},{"Add":" pub fn command_id(&self) -> u8 {"},{"Add":" self.command_id"},{"Add":" }"},{"Add":""},{"Add":" pub fn parameters(&self) -> &[u8] {"},{"Add":" self.parameters.as_ref()"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[derive(Debug)]"},{"Add":"pub enum DeviceCommand {"},{"Add":" SerialApiStarted(SerialApiStarted),"},{"Add":" Unknown(RawCommandData),"},{"Add":"}"},{"Add":""},{"Add":"impl TryFrom for DeviceCommand {"},{"Add":" type Error = ();"},{"Add":""},{"Add":" fn try_from(value: RawCommandData) -> Result {"},{"Add":" match value.command_id() {"},{"Add":" 0x0A => Ok(DeviceCommand::SerialApiStarted(value.try_into()?)),"},{"Add":" _ => Ok(DeviceCommand::Unknown(value)),"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[derive(Debug)]"},{"Add":"pub enum HostCommand {"},{"Add":" SoftReset,"},{"Add":" Unknown(RawCommandData),"},{"Add":"}"},{"Add":""},{"Add":"impl From for RawCommandData {"},{"Add":" fn from(command: HostCommand) -> Self {"},{"Add":" match command {"},{"Add":" HostCommand::SoftReset => Self {"},{"Add":" command_id: 0x08,"},{"Add":" ..Default::default()"},{"Add":" },"},{"Add":" HostCommand::Unknown(data) => data,"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[derive("},{"Add":" Debug, Clone, Copy, IntoPrimitive, TryFromPrimitive, PartialEq, Eq, PartialOrd, Ord, Hash,"},{"Add":")]"},{"Add":"#[repr(u8)]"},{"Add":"pub enum SerialApiWakeUpReason {"},{"Add":" /// The Z-Wave API Module has been woken up by reset or external interrupt."},{"Add":" Reset = 0x00,"},{"Add":" /// The Z-Wave API Module has been woken up by a timer."},{"Add":" WakeUpTimer = 0x01,"},{"Add":" /// The Z-Wave API Module has been woken up by a Wake Up Beam."},{"Add":" WakeUpBeam = 0x02,"},{"Add":" /// The Z-Wave API Module has been woken up by a reset triggered by the watchdog."},{"Add":" WatchdogReset = 0x03,"},{"Add":" /// The Z-Wave API Module has been woken up by an external interrupt."},{"Add":" ExternalInterrupt = 0x04,"},{"Add":" /// The Z-Wave API Module has been woken up by a powering up."},{"Add":" PowerUp = 0x05,"},{"Add":" /// The Z-Wave API Module has been woken up by USB Suspend."},{"Add":" USBSuspend = 0x06,"},{"Add":" /// The Z-Wave API Module has been woken up by a reset triggered by software."},{"Add":" SoftwareReset = 0x07,"},{"Add":" /// The Z-Wave API Module has been woken up by an emergency watchdog reset."},{"Add":" EmergencyWatchdogReset = 0x08,"},{"Add":" /// The Z-Wave API Module has been woken up by a reset triggered by brownout circuit."},{"Add":" BrownoutCircuit = 0x09,"},{"Add":" /// The Z-Wave API Module has been woken up by an unknown reason."},{"Add":" Unknown = 0xff,"},{"Add":"}"},{"Add":""},{"Add":"#[derive(Debug)]"},{"Add":"pub struct SerialApiStarted {"},{"Add":" wake_up_reason: SerialApiWakeUpReason,"},{"Add":" watch_dog_enabled: bool,"},{"Add":" device_options: DeviceOptions,"},{"Add":" generic_device_class: u8,"},{"Add":" specific_device_class: u8,"},{"Add":" supported_command_classes: Vec,"},{"Add":" supported_protocols: DeviceProtocols,"},{"Add":"}"},{"Add":""},{"Add":"#[derive(Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash)]"},{"Add":"pub struct DeviceOptions(u8);"},{"Add":""},{"Add":"impl DeviceOptions {"},{"Add":" pub fn value(&self) -> u8 {"},{"Add":" self.0"},{"Add":" }"},{"Add":""},{"Add":" pub fn listening(&self) -> bool {"},{"Add":" (self.0 & 0b1000_0000) != 0"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl core::fmt::Debug for DeviceOptions {"},{"Add":" fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {"},{"Add":" let mut f = f.debug_set();"},{"Add":" let mut f = if (self.listening()) {"},{"Add":" f.entry(&\"listening\")"},{"Add":" } else {"},{"Add":" &mut f"},{"Add":" };"},{"Add":" f.finish()"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl From for DeviceOptions {"},{"Add":" fn from(byte: u8) -> Self {"},{"Add":" Self(byte)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct DeviceProtocols(u8);"},{"Add":""},{"Add":"impl DeviceProtocols {"},{"Add":" pub fn value(&self) -> u8 {"},{"Add":" self.0"},{"Add":" }"},{"Add":""},{"Add":" pub fn long_range(&self) -> bool {"},{"Add":" (self.0 & 0b0000_0001) != 0"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl Default for DeviceProtocols {"},{"Add":" fn default() -> Self {"},{"Add":" Self(Default::default())"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl core::fmt::Debug for DeviceProtocols {"},{"Add":" fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {"},{"Add":" let mut f = f.debug_set();"},{"Add":" let mut f = if (self.long_range()) {"},{"Add":" f.entry(&\"long_range\")"},{"Add":" } else {"},{"Add":" &mut f"},{"Add":" };"},{"Add":" f.finish()"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl From for DeviceProtocols {"},{"Add":" fn from(byte: u8) -> Self {"},{"Add":" Self(byte)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl TryFrom for SerialApiStarted {"},{"Add":" type Error = ();"},{"Add":""},{"Add":" fn try_from(value: RawCommandData) -> Result {"},{"Add":" if value.command_id() != 0x0A {"},{"Add":" return Err(());"},{"Add":" }"},{"Add":""},{"Add":" // FIXME: All of this is shit"},{"Add":" let wake_up_reason = value.parameters()[0].try_into().map_err(|_| ())?;"},{"Add":" let watch_dog_enabled = value.parameters()[1] != 0;"},{"Add":" let device_options = value.parameters()[2].into();"},{"Add":" let generic_device_class = value.parameters()[3];"},{"Add":" let specific_device_class = value.parameters()[4];"},{"Add":" let supported_command_classes_len = value.parameters()[5] as usize;"},{"Add":" let supported_command_classes ="},{"Add":" value.parameters()[6..(6 + supported_command_classes_len)].to_vec();"},{"Add":""},{"Add":" let supported_protocols = if value.parameters().len() > 6 + supported_command_classes_len {"},{"Add":" value.parameters()[6 + supported_command_classes_len].into()"},{"Add":" } else {"},{"Add":" Default::default()"},{"Add":" };"},{"Add":""},{"Add":" Ok(Self {"},{"Add":" wake_up_reason,"},{"Add":" watch_dog_enabled,"},{"Add":" device_options,"},{"Add":" generic_device_class,"},{"Add":" specific_device_class,"},{"Add":" supported_command_classes,"},{"Add":" supported_protocols,"},{"Add":" })"},{"Add":" }"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"Cargo.toml","metadata":0},"context":[{"change":0,"pos":344}],"contents":[{"Add":"[package]"},{"Add":"name = \"sockt-ecosystem-zwave\""},{"Add":"version = \"0.1.0\""},{"Add":"edition = \"2021\""},{"Add":""},{"Add":"[dependencies]"},{"Add":"serialport = \"4.2\""},{"Add":"thiserror = \"1.0\""},{"Add":"tracing = \"0.1\""},{"Add":"tracing-subscriber = \"0.3\""},{"Add":"num_enum = \"0.5\""},{"Add":""},{"Add":"[dev-dependencies]"},{"Add":"mockall = \"0.11\""}]}}],"owner":"sockt","repo":"ecosystem-zwave","token":"n4tI33yPytfkodQvdkGBpVYd7bvvokXPH1X/9CPBaRo=","login":null}

…

Dependencies

Change contents