From 6f0d2587b43bc451acd455ef660d7b816657a1bf Mon Sep 17 00:00:00 2001 From: Nicola Belluti Date: Sun, 5 May 2024 21:49:00 +0200 Subject: [PATCH] Added the Record struct --- Cargo.lock | 281 ++++++++++++++++++++++++++++++++++++++++++++++++++ Cargo.toml | 1 + src/lib.rs | 149 +------------------------- src/main.rs | 5 - src/r701.rs | 145 ++++++++++++++++++++++++++ src/record.rs | 117 +++++++++++++++++++++ 6 files changed, 548 insertions(+), 150 deletions(-) delete mode 100644 src/main.rs create mode 100644 src/r701.rs create mode 100644 src/record.rs diff --git a/Cargo.lock b/Cargo.lock index 40d4ed9..ecef3a6 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -2,6 +2,287 @@ # It is not intended for manual editing. version = 3 +[[package]] +name = "android-tzdata" +version = "0.1.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e999941b234f3131b00bc13c22d06e8c5ff726d1b6318ac7eb276997bbb4fef0" + +[[package]] +name = "android_system_properties" +version = "0.1.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "819e7219dbd41043ac279b19830f2efc897156490d7fd6ea916720117ee66311" +dependencies = [ + "libc", +] + +[[package]] +name = "autocfg" +version = "1.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0c4b4d0bd25bd0b74681c0ad21497610ce1b7c91b1022cd21c80c6fbdd9476b0" + +[[package]] +name = "bumpalo" +version = "3.16.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "79296716171880943b8470b5f8d03aa55eb2e645a4874bdbb28adb49162e012c" + +[[package]] +name = "cc" +version = "1.0.96" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "065a29261d53ba54260972629f9ca6bffa69bac13cd1fed61420f7fa68b9f8bd" + +[[package]] +name = "cfg-if" +version = "1.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd" + +[[package]] +name = "chrono" +version = "0.4.38" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "a21f936df1771bf62b77f047b726c4625ff2e8aa607c01ec06e5a05bd8463401" +dependencies = [ + "android-tzdata", + "iana-time-zone", + "num-traits", + "windows-targets", +] + +[[package]] +name = "core-foundation-sys" +version = "0.8.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "06ea2b9bc92be3c2baa9334a323ebca2d6f074ff852cd1d7b11064035cd3868f" + +[[package]] +name = "iana-time-zone" +version = "0.1.60" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e7ffbb5a1b541ea2561f8c41c087286cc091e21e556a4f09a8f6cbf17b69b141" +dependencies = [ + "android_system_properties", + "core-foundation-sys", + "iana-time-zone-haiku", + "js-sys", + "wasm-bindgen", + "windows-core", +] + +[[package]] +name = "iana-time-zone-haiku" +version = "0.1.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f31827a206f56af32e590ba56d5d2d085f558508192593743f16b2306495269f" +dependencies = [ + "cc", +] + +[[package]] +name = "js-sys" +version = "0.3.69" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "29c15563dc2726973df627357ce0c9ddddbea194836909d655df6a75d2cf296d" +dependencies = [ + "wasm-bindgen", +] + +[[package]] +name = "libc" +version = "0.2.154" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ae743338b92ff9146ce83992f766a31066a91a8c84a45e0e9f21e7cf6de6d346" + +[[package]] +name = "log" +version = "0.4.21" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "90ed8c1e510134f979dbc4f070f87d4313098b704861a105fe34231c70a3901c" + +[[package]] +name = "num-traits" +version = "0.2.19" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "071dfc062690e90b734c0b2273ce72ad0ffa95f0c74596bc250dcfd960262841" +dependencies = [ + "autocfg", +] + +[[package]] +name = "once_cell" +version = "1.19.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3fdb12b2476b595f9358c5161aa467c2438859caa136dec86c26fdd2efe17b92" + +[[package]] +name = "proc-macro2" +version = "1.0.81" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3d1597b0c024618f09a9c3b8655b7e430397a36d23fdafec26d6965e9eec3eba" +dependencies = [ + "unicode-ident", +] + +[[package]] +name = "quote" +version = "1.0.36" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0fa76aaf39101c457836aec0ce2316dbdc3ab723cdda1c6bd4e6ad4208acaca7" +dependencies = [ + "proc-macro2", +] + [[package]] name = "r701" version = "0.1.0" +dependencies = [ + "chrono", +] + +[[package]] +name = "syn" +version = "2.0.60" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "909518bc7b1c9b779f1bbf07f2929d35af9f0f37e47c6e9ef7f9dddc1e1821f3" +dependencies = [ + "proc-macro2", + "quote", + "unicode-ident", +] + +[[package]] +name = "unicode-ident" +version = "1.0.12" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3354b9ac3fae1ff6755cb6db53683adb661634f67557942dea4facebec0fee4b" + +[[package]] +name = "wasm-bindgen" +version = "0.2.92" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4be2531df63900aeb2bca0daaaddec08491ee64ceecbee5076636a3b026795a8" +dependencies = [ + "cfg-if", + "wasm-bindgen-macro", +] + +[[package]] +name = "wasm-bindgen-backend" +version = "0.2.92" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "614d787b966d3989fa7bb98a654e369c762374fd3213d212cfc0251257e747da" +dependencies = [ + "bumpalo", + "log", + "once_cell", + "proc-macro2", + "quote", + "syn", + "wasm-bindgen-shared", +] + +[[package]] +name = "wasm-bindgen-macro" +version = "0.2.92" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "a1f8823de937b71b9460c0c34e25f3da88250760bec0ebac694b49997550d726" +dependencies = [ + "quote", + "wasm-bindgen-macro-support", +] + +[[package]] +name = "wasm-bindgen-macro-support" +version = "0.2.92" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e94f17b526d0a461a191c78ea52bbce64071ed5c04c9ffe424dcb38f74171bb7" +dependencies = [ + "proc-macro2", + "quote", + "syn", + "wasm-bindgen-backend", + "wasm-bindgen-shared", +] + +[[package]] +name = "wasm-bindgen-shared" +version = "0.2.92" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "af190c94f2773fdb3729c55b007a722abb5384da03bc0986df4c289bf5567e96" + +[[package]] +name = "windows-core" +version = "0.52.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "33ab640c8d7e35bf8ba19b884ba838ceb4fba93a4e8c65a9059d08afcfc683d9" +dependencies = [ + "windows-targets", +] + +[[package]] +name = "windows-targets" +version = "0.52.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6f0713a46559409d202e70e28227288446bf7841d3211583a4b53e3f6d96e7eb" +dependencies = [ + "windows_aarch64_gnullvm", + "windows_aarch64_msvc", + "windows_i686_gnu", + "windows_i686_gnullvm", + "windows_i686_msvc", + "windows_x86_64_gnu", + "windows_x86_64_gnullvm", + "windows_x86_64_msvc", +] + +[[package]] +name = "windows_aarch64_gnullvm" +version = "0.52.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7088eed71e8b8dda258ecc8bac5fb1153c5cffaf2578fc8ff5d61e23578d3263" + +[[package]] +name = "windows_aarch64_msvc" +version = "0.52.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9985fd1504e250c615ca5f281c3f7a6da76213ebd5ccc9561496568a2752afb6" + +[[package]] +name = "windows_i686_gnu" +version = "0.52.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "88ba073cf16d5372720ec942a8ccbf61626074c6d4dd2e745299726ce8b89670" + +[[package]] +name = "windows_i686_gnullvm" +version = "0.52.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "87f4261229030a858f36b459e748ae97545d6f1ec60e5e0d6a3d32e0dc232ee9" + +[[package]] +name = "windows_i686_msvc" +version = "0.52.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "db3c2bf3d13d5b658be73463284eaf12830ac9a26a90c717b7f771dfe97487bf" + +[[package]] +name = "windows_x86_64_gnu" +version = "0.52.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4e4246f76bdeff09eb48875a0fd3e2af6aada79d409d33011886d3e1581517d9" + +[[package]] +name = "windows_x86_64_gnullvm" +version = "0.52.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "852298e482cd67c356ddd9570386e2862b5673c85bd5f88df9ab6802b334c596" + +[[package]] +name = "windows_x86_64_msvc" +version = "0.52.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "bec47e5bfd1bff0eeaf6d8b485cc1074891a197ab4225d504cb7a1ab88b02bf0" diff --git a/Cargo.toml b/Cargo.toml index 6724dd9..fb322da 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -6,3 +6,4 @@ edition = "2021" # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html [dependencies] +chrono = { version = "0.4.38", default-features = false, features = ["clock"] } diff --git a/src/lib.rs b/src/lib.rs index e54a493..f50a48f 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -1,145 +1,4 @@ -use std::io::{BufRead, BufReader, Error, ErrorKind::InvalidData, Result, Write}; -use std::net::{TcpStream, ToSocketAddrs}; - -#[derive(Debug)] -pub struct R701 { - tcp_stream: TcpStream, - sequence_number: u16, -} - -impl R701 { - pub fn connect(connection_info: impl ToSocketAddrs) -> Result { - // Create a new R701 struct - let mut new = Self { - tcp_stream: TcpStream::connect(connection_info)?, - sequence_number: 0, - }; - - // Try to ping the endpoint - new.ping()?; - Ok(new) - } - - pub fn request(&mut self, payload: &[u8; 12]) -> Result> { - // Create a blank request - let mut request = [0x55, 0xaa, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]; - - // Insert the payload - request[2..14].clone_from_slice(payload); - - // Insert the sequence number - request[14..].clone_from_slice(&self.sequence_number.to_le_bytes()); - self.sequence_number += 1; - - // Send the request - self.tcp_stream.write_all(&request)?; - - // Create a buffer and return the response - let mut buffer = BufReader::new(&self.tcp_stream); - Ok(buffer.fill_buf()?.to_vec()) - } - - pub fn ping(&mut self) -> Result<()> { - // Create a request with a payload of `01 80 00 00 00 00 00 00 00 00 00 - // 00` and get the response - let response = self.request(&[0x01, 0x80, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0])?; - - // If the response is not `aa 55 01 01 00 00 00 00 00 00` then return an - // error - if response != [0xaa, 0x55, 0x01, 0x01, 0, 0, 0, 0, 0, 0] { - return Err(Error::new(InvalidData, "Malformed response")); - } - - Ok(()) - } - - pub fn get_name(&mut self, id: u32) -> Result> { - // Create a request with a payload of `01 c7 xx xx xx xx 00 00 00 00 14 - // 00`, where `xx xx xx xx` is the employee ID in little endian - let mut request = [0x01, 0xc7, 0, 0, 0, 0, 0, 0, 0, 0, 0x14, 0]; - request[2..6].clone_from_slice(&id.to_le_bytes()); - - // Get the response - let response = self.request(&request)?; - - // If the response lenght is right but the header is `01 00 00 00 00 00 - // 00 00` then the request is been succesful but the name was not found - if response[..12] == [0xaa, 0x55, 0x01, 0, 0, 0, 0, 0, 0, 0, 0x55, 0xaa] - && response.len() == 34 - { - return Ok(None); - } - - // If one between the response length or the response header is wrong - // return an error - if response[..12] != [0xaa, 0x55, 0x01, 0x01, 0, 0, 0, 0, 0, 0, 0x55, 0xaa] - || response.len() != 34 - { - return Err(Error::new(InvalidData, "Malformed response")); - } - - // Get the name as a UTF-8 string and delete the `\0` at the end - Ok(Some( - String::from_utf8_lossy(&response[12..22]) - .trim_end_matches(char::from(0)) - .to_string(), - )) - } - - pub fn get_total_record_count(&mut self) -> Result { - // Create a request with a payload of `01 b4 08 00 00 00 00 00 ff ff 00 - // 00` and get the response - let response = self.request(&[0x01, 0xb4, 0x08, 0, 0, 0, 0, 0, 0xff, 0xff, 0, 0])?; - - // If one between the response length or the response header is wrong - // return an error - if response[..4] != [0xaa, 0x55, 0x01, 0x01] - || response[6..] != [0u8; 4] - || response.len() != 10 - { - return Err(Error::new(InvalidData, "Malformed response")); - } - - // Convert the payload into a u16 and return it - let mut record_count_le = [0u8; 2]; - record_count_le.clone_from_slice(&response[4..6]); - Ok(u16::from_le_bytes(record_count_le)) - } - - pub fn get_record_bytes( - &mut self, - total_records: u16, - sequence_number: u16, - ) -> Result> { - // Create a request with a payload of `01 a4 00 00 00 00 xx xx xx xx 00 - // 04`, where `xx xx xx xx` changes meaning based on the sequence_number - // value - let mut request: [u8; 12] = [0x01, 0xa4, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0x04]; - - // If sequence_number is 0 then `xx xx xx xx` is `xx xx 00 00`, where - // `xx xx` is total_records in little endian - // - // Else `xx xx xx xx` is `00 00 xx xx`, where `xx xx` is sequence_number - // in little endian - if sequence_number == 0 { - request[6..8].clone_from_slice(&total_records.to_le_bytes()); - } else { - request[8..10].clone_from_slice(&sequence_number.to_le_bytes()); - } - - // Get the response - let response = self.request(&request)?; - - // If one between the response length, the response header or the last - // two bits is wrong return an error - if response[..12] != [0xaa, 0x55, 0x01, 0x01, 0, 0, 0, 0, 0, 0, 0x55, 0xaa] - || response[1036..] != [0, 0] - || response.len() != 1038 - { - return Err(Error::new(InvalidData, "Malformed response")); - } - - // Return only the payload bits as a vector - Ok(response[12..response.len() - 2].to_vec()) - } -} +mod r701; +mod record; +pub use r701::R701; +pub use record::{Clock, Record}; diff --git a/src/main.rs b/src/main.rs deleted file mode 100644 index 7239828..0000000 --- a/src/main.rs +++ /dev/null @@ -1,5 +0,0 @@ -use r701::R701; - -fn main() { - let _r701 = R701::connect("127.0.0.1:5005").unwrap(); -} diff --git a/src/r701.rs b/src/r701.rs new file mode 100644 index 0000000..4d2cad0 --- /dev/null +++ b/src/r701.rs @@ -0,0 +1,145 @@ +use std::io::{BufRead, BufReader, Error, ErrorKind::InvalidData, Result, Write}; +use std::net::{TcpStream, ToSocketAddrs}; + +#[derive(Debug)] +pub struct R701 { + tcp_stream: TcpStream, + sequence_number: u16, +} + +impl R701 { + pub fn connect(connection_info: impl ToSocketAddrs) -> Result { + // Create a new R701 struct + let mut new = Self { + tcp_stream: TcpStream::connect(connection_info)?, + sequence_number: 0, + }; + + // Try to ping the endpoint + new.ping()?; + Ok(new) + } + + pub fn request(&mut self, payload: &[u8; 12]) -> Result> { + // Create a blank request + let mut request = [0x55, 0xaa, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]; + + // Insert the payload + request[2..14].clone_from_slice(payload); + + // Insert the sequence number + request[14..].clone_from_slice(&self.sequence_number.to_le_bytes()); + self.sequence_number += 1; + + // Send the request + self.tcp_stream.write_all(&request)?; + + // Create a buffer and return the response + let mut buffer = BufReader::new(&self.tcp_stream); + Ok(buffer.fill_buf()?.to_vec()) + } + + pub fn ping(&mut self) -> Result<()> { + // Create a request with a payload of `01 80 00 00 00 00 00 00 00 00 00 + // 00` and get the response + let response = self.request(&[0x01, 0x80, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0])?; + + // If the response is not `aa 55 01 01 00 00 00 00 00 00` then return an + // error + if response != [0xaa, 0x55, 0x01, 0x01, 0, 0, 0, 0, 0, 0] { + return Err(Error::new(InvalidData, "Malformed response")); + } + + Ok(()) + } + + pub fn get_name(&mut self, id: u32) -> Result> { + // Create a request with a payload of `01 c7 xx xx xx xx 00 00 00 00 14 + // 00`, where `xx xx xx xx` is the employee ID in little endian + let mut request = [0x01, 0xc7, 0, 0, 0, 0, 0, 0, 0, 0, 0x14, 0]; + request[2..6].clone_from_slice(&id.to_le_bytes()); + + // Get the response + let response = self.request(&request)?; + + // If the response length is right but the header is `01 00 00 00 00 00 + // 00 00` then the request is been succesful but the name was not found + if response[..12] == [0xaa, 0x55, 0x01, 0, 0, 0, 0, 0, 0, 0, 0x55, 0xaa] + && response.len() == 34 + { + return Ok(None); + } + + // If one between the response length or the response header is wrong + // return an error + if response[..12] != [0xaa, 0x55, 0x01, 0x01, 0, 0, 0, 0, 0, 0, 0x55, 0xaa] + || response.len() != 34 + { + return Err(Error::new(InvalidData, "Malformed response")); + } + + // Get the name as a UTF-8 string and delete the `\0` at the end + Ok(Some( + String::from_utf8_lossy(&response[12..22]) + .trim_end_matches(char::from(0)) + .to_string(), + )) + } + + pub fn get_total_record_count(&mut self) -> Result { + // Create a request with a payload of `01 b4 08 00 00 00 00 00 ff ff 00 + // 00` and get the response + let response = self.request(&[0x01, 0xb4, 0x08, 0, 0, 0, 0, 0, 0xff, 0xff, 0, 0])?; + + // If one between the response length or the response header is wrong + // return an error + if response[..4] != [0xaa, 0x55, 0x01, 0x01] + || response[6..] != [0u8; 4] + || response.len() != 10 + { + return Err(Error::new(InvalidData, "Malformed response")); + } + + // Convert the payload into a u16 and return it + let mut record_count_le = [0u8; 2]; + record_count_le.clone_from_slice(&response[4..6]); + Ok(u16::from_le_bytes(record_count_le)) + } + + pub fn get_record_bytes( + &mut self, + total_records: u16, + sequence_number: u16, + ) -> Result> { + // Create a request with a payload of `01 a4 00 00 00 00 xx xx xx xx 00 + // 04`, where `xx xx xx xx` changes meaning based on the sequence_number + // value + let mut request: [u8; 12] = [0x01, 0xa4, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0x04]; + + // If sequence_number is 0 then `xx xx xx xx` is `xx xx 00 00`, where + // `xx xx` is total_records in little endian + // + // Else `xx xx xx xx` is `00 00 xx xx`, where `xx xx` is sequence_number + // in little endian + if sequence_number == 0 { + request[6..8].clone_from_slice(&total_records.to_le_bytes()); + } else { + request[8..10].clone_from_slice(&sequence_number.to_le_bytes()); + } + + // Get the response + let response = self.request(&request)?; + + // If one between the response length, the response header or the last + // two bits is wrong return an error + if response[..12] != [0xaa, 0x55, 0x01, 0x01, 0, 0, 0, 0, 0, 0, 0x55, 0xaa] + || response[1036..] != [0, 0] + || response.len() != 1038 + { + return Err(Error::new(InvalidData, "Malformed response")); + } + + // Return only the payload bits as a vector + Ok(response[12..response.len() - 2].to_vec()) + } +} diff --git a/src/record.rs b/src/record.rs new file mode 100644 index 0000000..df8bd8b --- /dev/null +++ b/src/record.rs @@ -0,0 +1,117 @@ +use chrono::{DateTime, Local, TimeZone}; + +#[derive(Debug, Clone, Copy, Default, Eq, PartialEq, Ord, PartialOrd, Hash)] +pub enum Clock { + #[default] + FirstIn, + FirstOut, + SecondIn, + SecondOut, +} + +unsafe impl Send for Clock {} +unsafe impl Sync for Clock {} + +#[derive(Debug, Clone, Copy, Default, Eq, PartialEq, Ord, PartialOrd, Hash)] +pub struct Record { + pub employee_id: u32, + pub clock: Clock, + pub datetime: DateTime, +} + +unsafe impl Send for Record {} +unsafe impl Sync for Record {} + +impl TryFrom<&[u8]> for Record { + type Error = &'static str; + + fn try_from(record_bytes: &[u8]) -> Result { + // Return an error if the slice length is less than 12 + if record_bytes.len() < 12 { + return Err("Slice must be at least of length 12 to be converted into Record"); + } + + // Extract the employee ID from the central 4 bytes of the record in + // little endian + let mut employee_id = [0u8; 4]; + employee_id.clone_from_slice(&record_bytes[4..8]); + let employee_id = u32::from_le_bytes(employee_id); + + // Extract the DateTime from the last 4 bytes of the record in little + // endian + let mut datetime = [0u8; 4]; + datetime.clone_from_slice(&record_bytes[8..12]); + let datetime = u32::from_le_bytes(datetime); + + // Return a new Record + Ok(Self { + employee_id, + clock: match record_bytes[1] >> 6 { + 0 => Clock::FirstIn, + 1 => Clock::FirstOut, + 2 => Clock::SecondIn, + 3 => Clock::SecondOut, + _ => panic!("Math has broken"), + }, + datetime: Local + .with_ymd_and_hms( + // DateTime data is in this format: + // + // mmmmmmhh hhhddddd MMMMyyyy yyyyyyyy + // + // Using some bitshifts and some bitwise operations we can + // extract the data and put it into a DateTime struct + (datetime & 0x0fff) as i32, + (datetime >> 12) & 0x0f, + (datetime >> 16) & 0x1f, + (datetime >> 21) & 0x1f, + (datetime >> 26) & 0x3f, + 0, + ) + .single() + .ok_or("DateTime conversion error")?, + }) + } +} + +#[cfg(test)] +mod tests { + use super::*; + + #[test] + fn valid_record_conversion() { + let record_bytes: &[u8] = &[0x10, 0x23, 0x0b, 0x1d, 0x01, 0, 0, 0, 0xb2, 0x17, 0x01, 0]; + + assert_eq!( + record_bytes.try_into(), + Ok(Record { + employee_id: 1, + clock: Clock::FirstIn, + datetime: Local + .with_ymd_and_hms(1970, 1, 1, 0, 0, 0) + .single() + .unwrap(), + }) + ) + } + + #[test] + fn invalid_length() { + let record_bytes: &[u8] = &[0u8; 11]; + + assert_eq!( + record_bytes.try_into(), + Err::("Slice must be at least of length 12 to be converted into Record") + ) + } + + #[test] + fn invalid_datetime() { + let record_bytes: &[u8] = &[0x10, 0x23, 0x0b, 0x1d, 0x01, 0, 0, 0, 0xb2, 0x17, 0x20, 0]; + + assert_eq!( + record_bytes.try_into(), + Err::("DateTime conversion error") + ) + } +}