diff --git a/src/netmd/factory/factory_commands.rs b/src/netmd/factory/factory_commands.rs
new file mode 100644
index 0000000..c67d45d
--- /dev/null
+++ b/src/netmd/factory/factory_commands.rs
@@ -0,0 +1,68 @@
+use crate::netmd::interface::InterfaceError;
+
+use super::factory_interface::{DisplayMode, MemoryOpenType, MemoryType, NetMDFactoryInterface};
+
+pub enum PatchPeripheralBase{
+    NetMD   = 0x03802000,
+    HiMD    = 0x03804000,
+}
+
+pub async fn display_string(
+    interface: &mut NetMDFactoryInterface<'_>,
+    text: String,
+    blink: bool,
+) -> Result<(), InterfaceError> {
+    interface.set_display_mode(DisplayMode::Override).await?;
+    interface.set_display_override_string(text, blink).await?;
+    Ok(())
+}
+
+/*
+pub async fn clean_read(
+    &mut self,
+    address: u32,
+    length: u32,
+    mem_type: MemoryType,
+    encrypted: bool,
+    auto_decrypt: bool,
+) -> Result<(), InterfaceError> {
+    self.factory_interface.change_memory_state(address, length, mem_type, MemoryOpenType::Read, encrypted).await?;
+    let res = self.factory_interface.read(address, length, mem_type).await?;
+    self.factory_interface.change_memory_state(address, length, mem_type, MemoryOpenType::Close, encrypted).await?;
+
+    if encrypted && auto_decrypt {
+
+    }
+
+    Ok(())
+}
+*/
+
+pub async fn get_descriptive_device_code(
+    interface: &mut NetMDFactoryInterface<'_>,
+) -> Result<String, InterfaceError> {
+    let (
+        chip_type,
+            _hwid,
+            version,
+            subversion
+    ) = interface.get_device_code().await?;
+
+    let code = match chip_type {
+        0x20 => "R", // Type-R
+        0x21 => "S", // Type-S
+        0x23 => "Hp", // DH10P
+        0x22 => "Hn", // MZ-NH*
+        0x24 => "Hr", // MZ-RH*
+        0x25 => "Hx", // MZ-RH1
+        _ => &format!("{}", chip_type),
+    };
+    let mut code = code.to_string();
+
+    let version: Vec<char> = version.to_string().chars().collect();
+    let (maj, min) = (version[0], version[1]);
+
+    code.push_str(&format!("{maj}.{min}{:02X}", subversion));
+
+    Ok(code)
+}
diff --git a/src/netmd/factory/factory_interface.rs b/src/netmd/factory/factory_interface.rs
new file mode 100644
index 0000000..68d1df8
--- /dev/null
+++ b/src/netmd/factory/factory_interface.rs
@@ -0,0 +1,364 @@
+use std::time::Duration;
+
+use log::debug;
+
+use crate::netmd::{base::NetMDError, interface::{InterfaceError, NetmdStatus}, query_utils::{format_query, scan_query, QueryValue}, utils::{cross_sleep, to_sjis}, NetMD};
+
+
+#[derive(Clone, Copy, Debug)]
+pub enum MemoryType {
+    Mapped = 0x0,
+    Eeprom2 = 0x2,
+    Eeprom3 = 0x3,
+}
+
+#[derive(Clone, Copy, Debug)]
+pub enum MemoryOpenType {
+    Close = 0x0,
+    Read = 0x1,
+    Write = 0x2,
+    ReadWrite = 0x3,
+}
+
+#[derive(Clone, Copy, Debug)]
+pub enum DisplayMode {
+    Default = 0x0,
+    Override = 0x1,
+}
+
+fn calculate_checksum(data: &[u8], seed: u32) -> u32 {
+    let mut crc = seed;
+
+    let mut tmp = data.len();
+    data.iter().for_each(|e| {
+        tmp = (tmp & 0xffff0000) | *e as usize;
+
+        crc ^= tmp as u32;
+        for i in 0..16 {
+            let ts = crc & 0x8000;
+            crc <<= i;
+            if ts >= 1 {
+                crc ^= 0x1021;
+            }
+        }
+    });
+
+    crc = (crc & 0xffff) >> 0;
+
+    crc
+}
+
+fn calculate_eeprom_checksum(data: &[u8], seed: u32) -> u32 {
+    let mut crc = seed;
+
+    let mut tmp = data.len();
+
+    // Convert the input into its little endian 16 bit representation
+    let new_data: Vec<u16> = data
+        .clone()
+        .chunks(2)
+        .map(|c| u16::from_le_bytes(c.try_into().unwrap()))
+        .collect();
+
+    new_data.iter().for_each(|e| {
+        tmp = (tmp & 0xffff0000) | *e as usize;
+
+        crc ^= tmp as u32;
+        for i in 0..16 {
+            let ts = crc & 0x8000;
+            crc <<= i;
+            if ts >= 1 {
+                crc ^= 0x1021;
+            }
+        }
+    });
+
+    crc = (crc & 0xffff) >> 0;
+
+    crc
+}
+
+pub struct NetMDFactoryInterface<'a> {
+    device: &'a mut NetMD,
+}
+
+impl<'a> NetMDFactoryInterface<'a> {
+    /// The maximum number of times to retry after an interim response
+    const MAX_INTERIM_READ_ATTEMPTS: u8 = 4;
+
+    /// The amount of time to wait after an interim response (in milliseconds)
+    const INTERIM_RESPONSE_RETRY_INTERVAL: u32 = 100;
+
+    pub fn new(device: &'a mut NetMD) -> NetMDFactoryInterface<'_> {
+        Self { device }
+    }
+
+    pub async fn send_query(&mut self, query: &[u8], test: bool, accept_interim: bool) -> Result<Vec<u8>, InterfaceError> {
+        self.send_command(query, test).await?;
+        self.read_reply(accept_interim).await
+    }
+
+    pub async fn send_command(&mut self, query: &[u8], test: bool) -> Result<(), NetMDError> {
+        let mut final_buffer = query.to_vec();
+        if test {
+            final_buffer.insert(0, NetmdStatus::SpecificInquiry as u8);
+        } else {
+            final_buffer.insert(0, NetmdStatus::Control as u8)
+        }
+
+        self.device.send_factory_command(final_buffer).await
+    }
+
+    pub async fn read_reply(&mut self, accept_interim: bool) -> Result<Vec<u8>, InterfaceError> {
+        let mut current_attempt = 0;
+        let mut data;
+
+        while current_attempt < Self::MAX_INTERIM_READ_ATTEMPTS {
+            data = self.device.read_factory_reply(None).await?;
+
+            let status = NetmdStatus::try_from(data[0])?;
+            debug!("Device status: {:?}", status);
+
+            match status {
+                NetmdStatus::NotImplemented => {
+                    return Err(InterfaceError::NotImplemented(format!("{:02X?}", data)))
+                }
+                NetmdStatus::Rejected => {
+                    return Err(InterfaceError::Rejected(format!("{:02X?}", data)))
+                }
+                NetmdStatus::Interim if !accept_interim => {
+                    let sleep_time = Self::INTERIM_RESPONSE_RETRY_INTERVAL
+                        * (u32::pow(2, current_attempt as u32) - 1);
+
+                    cross_sleep(Duration::from_millis(sleep_time as u64)).await;
+
+                    current_attempt += 1;
+                    continue; // Retry!
+                }
+                NetmdStatus::Accepted | NetmdStatus::Implemented | NetmdStatus::Interim => {
+                    if current_attempt >= Self::MAX_INTERIM_READ_ATTEMPTS {
+                        return Err(InterfaceError::MaxRetries);
+                    }
+                    return Ok(data);
+                }
+                _ => return Err(InterfaceError::Unknown(format!("{:02X?}", data))),
+            }
+        }
+
+        // This should NEVER happen unless the code is changed wrongly
+        unreachable!("The max number of retries is set to 0!")
+    }
+
+    pub async fn auth(&mut self) -> Result<(), InterfaceError> {
+        let query = format_query("1801 ff0e 4e6574204d442057616c6b6d616e", vec![])?;
+
+        self.send_query(&query, false, false).await?;
+
+        Ok(())
+    }
+
+    pub async fn change_memory_state(
+        &mut self,
+        address: u32,
+        length: u32,
+        mem_type: MemoryType,
+        state: MemoryOpenType,
+        encrypted: bool
+    ) -> Result<(), InterfaceError> {
+        let encrypted = match encrypted {
+            true => 0x1,
+            false => 0x0,
+        };
+        let query = format_query(
+            "1820 ff %b %<d %b %b %b",
+            vec![
+                QueryValue::Number(mem_type as i64),
+                QueryValue::Number(address as i64),
+                QueryValue::Number(length as i64),
+                QueryValue::Number(state as i64),
+                QueryValue::Number(encrypted)
+            ]
+        )?;
+
+        self.send_query(&query, false, false).await?;
+
+        Ok(())
+    }
+
+    pub async fn read(
+        &mut self,
+        address: u32,
+        length: u32,
+        mem_type: MemoryType
+    ) -> Result<Vec<u8>, InterfaceError> {
+        let query = format_query(
+            "1821 ff %b %<d %b",
+            vec![
+                QueryValue::Number(mem_type as i64),
+                QueryValue::Number(address as i64),
+                QueryValue::Number(length as i64),
+            ]
+        )?;
+
+        let reply = self.send_query(&query, false, false).await?;
+        let res = scan_query(reply, "1821 00 %? %?%?%?%? %? %?%? %*")?;
+        let mut buf = res[0].to_vec().unwrap();
+        buf = buf[..buf.len() - 2].to_vec();
+
+        Ok(buf)
+    }
+
+    pub async fn write(
+        &mut self,
+        address: u32,
+        data: &[u8],
+        mem_type: MemoryType,
+    ) -> Result<(), InterfaceError> {
+        let checksum = calculate_checksum(data, 0);
+
+        let query = format_query(
+            "1822 ff %b %<d %b 0000 %* %<w",
+            vec![
+                QueryValue::Number(mem_type as i64),
+                QueryValue::Number(address as i64),
+                QueryValue::Number(data.len() as i64),
+                QueryValue::Array(data.to_vec()),
+                QueryValue::Number(checksum as i64),
+            ]
+        )?;
+
+        self.send_query(&query, false, false).await?;
+
+        Ok(())
+    }
+
+    pub async fn read_metadata_peripheral(
+        &mut self,
+        sector: u32,
+        offset: u32,
+        length: u32,
+    ) -> Result<Vec<u8>, InterfaceError> {
+        let query = format_query(
+            "1824 ff %<w %<w %b",
+            vec![
+                QueryValue::Number(sector as i64),
+                QueryValue::Number(offset as i64),
+                QueryValue::Number(length as i64),
+            ]
+        )?;
+
+        let reply = self.send_query(&query, false, false).await?;
+        let res = scan_query(reply, "1821 00 %? %?%?%?%? %? %?%? %*")?;
+
+        Ok(res[1].to_vec().unwrap())
+    }
+
+    pub async fn write_metadata_peripheral(
+        &mut self,
+        sector: u32,
+        offset: u32,
+        data: &[u8],
+    ) -> Result<(), InterfaceError> {
+        let query = format_query(
+            "1824 ff %<w %<w %b",
+            vec![
+                QueryValue::Number(sector as i64),
+                QueryValue::Number(offset as i64),
+                QueryValue::Array(data.to_vec()),
+            ]
+        )?;
+
+        self.send_query(&query, false, false).await?;
+        Ok(())
+    }
+
+    pub async fn set_display_mode(
+        &mut self,
+        mode: DisplayMode,
+    ) -> Result<(), InterfaceError> {
+        let query = format_query(
+            "1851 ff %b",
+            vec![
+                QueryValue::Number(mode as i64),
+            ]
+        )?;
+
+        self.send_query(&query, false, false).await?;
+        Ok(())
+    }
+
+    pub async fn set_display_override_string(
+        &mut self,
+        text: String,
+        blink: bool,
+    ) -> Result<(), InterfaceError> {
+        assert!(!text.len() < 9);
+
+        let blink = match blink {
+            true => 0x1,
+            false => 0x0,
+        };
+
+        let mut sjis_version = to_sjis(&text);
+        sjis_version.extend_from_slice(&vec![0u8; 10 - sjis_version.len()]);
+
+        let query = format_query(
+            "1852 ff %b %b 00 %*",
+            vec![
+                QueryValue::Number(0),
+                QueryValue::Number(blink),
+                QueryValue::Array(sjis_version),
+            ]
+        )?;
+
+        self.send_query(&query, false, false).await?;
+
+        Ok(())
+    }
+
+    pub async fn get_device_version(&mut self) -> Result<u32, InterfaceError> {
+        let query = format_query("1813 ff", vec![])?;
+        let reply = self.send_query(&query, false, false).await?;
+        let res = scan_query(reply, "1813 00 00 %B")?;
+
+        Ok(res[0].to_i64().unwrap().try_into().unwrap())
+    }
+
+    pub async fn get_device_code(&mut self) -> Result<(u8, u8, u8, u8), InterfaceError> {
+        let query = format_query("1812 ff", vec![])?;
+        let reply = self.send_query(&query, false, false).await?;
+        let res = scan_query(reply, "1812 00 %b %b %b %B")?;
+
+        let chip_type: u8 = res[0].to_i64().unwrap().try_into().unwrap();
+        let hwid: u8 = res[1].to_i64().unwrap().try_into().unwrap();
+        let subversion: u8 = res[2].to_i64().unwrap().try_into().unwrap();
+        let version: u8 = res[3].to_i64().unwrap().try_into().unwrap();
+
+        Ok((
+            chip_type,
+            hwid,
+            subversion,
+            version,
+        ))
+    }
+
+    pub async fn get_switch_status(&mut self) -> Result<(u16, u8, u8, u16), InterfaceError> {
+        let query = format_query("1853 ff", vec![])?;
+        let reply = self.send_query(&query, false, false).await?;
+        let res = scan_query(reply, "1853 ff %w %b %b %w")?;
+
+        let internal_microswitch: u16 = res[0].to_i64().unwrap().try_into().unwrap();
+        let button: u8 = res[1].to_i64().unwrap().try_into().unwrap();
+        let xy: u8 = res[2].to_i64().unwrap().try_into().unwrap();
+        let unlabeled: u16 = res[3].to_i64().unwrap().try_into().unwrap();
+
+        Ok((
+            internal_microswitch,
+            button,
+            xy,
+            unlabeled,
+        ))
+    }
+}
+
+
diff --git a/src/netmd/interface.rs b/src/netmd/interface.rs
index 72f28f4..bac7559 100644
--- a/src/netmd/interface.rs
+++ b/src/netmd/interface.rs
@@ -18,6 +18,8 @@ use thiserror::Error;
 
 use super::base::NetMD;
 use super::encryption::Encryptor;
+use super::factory::factory_commands::get_descriptive_device_code;
+use super::factory::factory_interface::NetMDFactoryInterface;
 use super::utils::{cross_sleep, to_sjis};
 
 /// An action to take on the player
@@ -192,7 +194,7 @@ enum DescriptorAction {
 
 #[derive(Copy, Clone, Debug)]
 #[repr(u8)]
-enum NetmdStatus {
+pub enum NetmdStatus {
     // NetMD Protocol return status (first byte of request)
     Control = 0x00,
     Status = 0x01,
@@ -336,13 +338,13 @@ impl NetMDInterface {
         )
         .await?;
 
-        let query = format_query("1809 00 ff00 0000 0000".to_string(), vec![])?;
+        let query = format_query("1809 00 ff00 0000 0000", vec![])?;
 
         let reply = self.send_query(&query, false, false).await?;
 
         let res = scan_query(
             reply,
-            "1809 00 1000 %?%? %?%? %w %b %b %b %b %w %*".to_string(),
+            "1809 00 1000 %?%? %?%? %w %b %b %b %b %w %*",
         )?;
 
         let _descriptor_length = res[0].to_i64().unwrap();
@@ -415,17 +417,23 @@ impl NetMDInterface {
         Err(InterfaceError::NoSupportedMedia)
     }
 
-    /* TODO: Finish implementation
-    fn factory(&mut self) -> Result<NetMDLevel, Box<dyn Error>> {
-        let device_name = self.net_md_device.device_name().expect("The device has no name");
+    // TODO: Finish implementation; needs to support Hi-MD mode and RH1 stuff
+    async fn factory(&mut self) -> Result<NetMDFactoryInterface, InterfaceError> {
+        let device_name = self.device.device_name().expect("The device has no name");
+        let himd = device_name.contains("MZ-RH") || device_name.contains("MZ-NH") || device_name.contains("DS-HMD1");
 
-        let himd = device_name.contains("MZ-RH") || device_name.contains("MZ-NH");
+        self.disc_subunit_identifier().await?;
+        let mut factory_interface = NetMDFactoryInterface::new(&mut self.device);
+        factory_interface.auth().await?;
+        /*
+        let device_code = get_descriptive_device_code(&mut factory_interface).await?;
+        if device_code.starts_with("Hx") {
+            factory_interface
+        }
+        */
 
-        self.disc_subunit_identifier()?;
-
-        let constructor =
+        Ok(factory_interface)
     }
-    */
 
     async fn net_md_level(&mut self) -> Result<NetMDLevel, InterfaceError> {
         let result = self.disc_subunit_identifier().await?;
@@ -438,7 +446,7 @@ impl NetMDInterface {
         descriptor: &Descriptor,
         action: &DescriptorAction,
     ) -> Result<(), InterfaceError> {
-        let mut query = format_query("1808".to_string(), vec![]).unwrap();
+        let mut query = format_query("1808", vec![]).unwrap();
 
         query.append(&mut descriptor.get_array());
 
@@ -528,13 +536,13 @@ impl NetMDInterface {
 
     async fn playback_control(&mut self, action: Action) -> Result<(), InterfaceError> {
         let query = format_query(
-            "18c3 ff %b 000000".to_string(),
+            "18c3 ff %b 000000",
             vec![QueryValue::Number(action as i64)],
         )?;
 
         let reply = self.send_query(&query, false, false).await?;
 
-        scan_query(reply, "18c3 00 %b 000000".to_string())?;
+        scan_query(reply, "18c3 00 %b 000000")?;
 
         Ok(())
     }
@@ -562,30 +570,30 @@ impl NetMDInterface {
     //TODO: Implement fix for LAM-1
     /// Stop playback
     pub async fn stop(&mut self) -> Result<(), InterfaceError> {
-        let query = format_query("18c5 ff 00000000".to_string(), vec![])?;
+        let query = format_query("18c5 ff 00000000", vec![])?;
 
         let reply = self.send_query(&query, false, false).await?;
 
-        scan_query(reply, "18c5 00 00000000".to_string())?;
+        scan_query(reply, "18c5 00 00000000")?;
 
         Ok(())
     }
 
     pub async fn acquire(&mut self) -> Result<(), InterfaceError> {
-        let query = format_query("ff 010c ffff ffff ffff ffff ffff ffff".to_string(), vec![])?;
+        let query = format_query("ff 010c ffff ffff ffff ffff ffff ffff", vec![])?;
         let reply = self.send_query(&query, false, false).await?;
 
-        scan_query(reply, "ff 010c ffff ffff ffff ffff ffff ffff".to_string())?;
+        scan_query(reply, "ff 010c ffff ffff ffff ffff ffff ffff")?;
 
         Ok(())
     }
 
     pub async fn release(&mut self) -> Result<(), InterfaceError> {
-        let query = format_query("ff 0100 ffff ffff ffff ffff ffff ffff".to_string(), vec![])?;
+        let query = format_query("ff 0100 ffff ffff ffff ffff ffff ffff", vec![])?;
 
         let reply = self.send_query(&query, false, false).await?;
 
-        scan_query(reply, "ff 0100 ffff ffff ffff ffff ffff ffff".to_string())?;
+        scan_query(reply, "ff 0100 ffff ffff ffff ffff ffff ffff")?;
 
         Ok(())
     }
@@ -598,7 +606,7 @@ impl NetMDInterface {
         .await?;
 
         let query = format_query(
-            "1809 8001 0230 8800 0030 8804 00 ff00 00000000".to_string(),
+            "1809 8001 0230 8800 0030 8804 00 ff00 00000000",
             vec![],
         )?;
 
@@ -606,7 +614,7 @@ impl NetMDInterface {
 
         let res = scan_query(
             reply,
-            "1809 8001 0230 8800 0030 8804 00 1000 00090000 %x".to_string(),
+            "1809 8001 0230 8800 0030 8804 00 1000 00090000 %x",
         )?;
 
         self.change_descriptor_state(&Descriptor::OperatingStatusBlock, &DescriptorAction::Close)
@@ -633,7 +641,7 @@ impl NetMDInterface {
         .await?;
 
         let query = format_query(
-            "1809 8001 0330 8802 0030 8805 0030 8806 00 ff00 00000000".to_string(),
+            "1809 8001 0330 8802 0030 8805 0030 8806 00 ff00 00000000",
             vec![],
         )
         .unwrap();
@@ -641,7 +649,7 @@ impl NetMDInterface {
 
         let result = scan_query(
             reply,
-            "1809 8001 0330 8802 0030 8805 0030 8806 00 1000 00%?0000 00%b 8806 %x".to_string(),
+            "1809 8001 0330 8802 0030 8805 0030 8806 00 1000 00%?0000 00%b 8806 %x",
         )?;
 
         let operating_status = result[1].to_vec().unwrap();
@@ -674,7 +682,7 @@ impl NetMDInterface {
         .await?;
 
         let query = format_query(
-            "1809 8001 0330 %w 0030 8805 0030 %w 00 ff00 00000000".to_string(),
+            "1809 8001 0330 %w 0030 8805 0030 %w 00 ff00 00000000",
             vec![QueryValue::Number(p1 as i64), QueryValue::Number(p2 as i64)],
         )?;
 
@@ -682,7 +690,7 @@ impl NetMDInterface {
 
         let res = scan_query(
             reply,
-            "1809 8001 0330 %?%? %?%? %?%? %?%? %?%? %? 1000 00%?0000 %x %?".to_string(),
+            "1809 8001 0330 %?%? %?%? %?%? %?%? %?%? %? 1000 00%?0000 %x %?",
         )?;
 
         self.change_descriptor_state(
@@ -710,7 +718,7 @@ impl NetMDInterface {
         ).await?;
 
         let query = format_query(
-            "1809 8001 0430 8802 0030 8805 0030 0003 0030 0002 00 ff00 00000000".to_string(),
+            "1809 8001 0430 8802 0030 8805 0030 0003 0030 0002 00 ff00 00000000",
             vec![],
         )
         .unwrap();
@@ -721,7 +729,7 @@ impl NetMDInterface {
             Err(_) => return Ok([0u16; 5]),
         };
 
-        let result = scan_query(reply, "1809 8001 0430 %?%? %?%? %?%? %?%? %?%? %?%? %?%? %? %?00 00%?0000 000b 0002 0007 00 %w %B %B %B %B".to_string())?;
+        let result = scan_query(reply, "1809 8001 0430 %?%? %?%? %?%? %?%? %?%? %?%? %?%? %? %?00 00%?0000 000b 0002 0007 00 %w %B %B %B %B")?;
 
         let final_result = [
             result[0].to_i64().unwrap() as u16,
@@ -741,7 +749,7 @@ impl NetMDInterface {
 
     /// Eject the disc from the player if supported
     pub async fn eject_disc(&mut self) -> Result<(), InterfaceError> {
-        let query = format_query("18c1 ff 6000".to_string(), vec![]).unwrap();
+        let query = format_query("18c1 ff 6000", vec![]).unwrap();
 
         let _reply = self.send_query(&query, false, false).await?;
 
@@ -750,7 +758,7 @@ impl NetMDInterface {
 
     /// Check if the machine has the capability to eject a disc
     pub async fn can_eject_disc(&mut self) -> Result<bool, InterfaceError> {
-        let query = format_query("18c1 ff 6000".to_string(), vec![]).unwrap();
+        let query = format_query("18c1 ff 6000", vec![]).unwrap();
 
         match self.send_query(&query, true, false).await {
             Ok(_) => Ok(true),
@@ -761,14 +769,14 @@ impl NetMDInterface {
     /// Move the playback to a specific track
     pub async fn go_to_track(&mut self, track_number: u16) -> Result<u16, InterfaceError> {
         let query = format_query(
-            "1850 ff010000 0000 %w".to_string(),
+            "1850 ff010000 0000 %w",
             vec![QueryValue::Number(track_number as i64)],
         )
         .unwrap();
 
         let reply = self.send_query(&query, false, false).await?;
 
-        let res = scan_query(reply, "1850 00010000 0000 %w".to_string())?;
+        let res = scan_query(reply, "1850 00010000 0000 %w")?;
 
         let value = res[0].to_i64().unwrap();
 
@@ -785,7 +793,7 @@ impl NetMDInterface {
         frame: u8,
     ) -> Result<u16, InterfaceError> {
         let query = format_query(
-            "1850 ff000000 0000 %w %B%B%B%B".to_string(),
+            "1850 ff000000 0000 %w %B%B%B%B",
             vec![
                 QueryValue::Number(track_number as i64),
                 QueryValue::Number(hour as i64),
@@ -798,7 +806,7 @@ impl NetMDInterface {
 
         let reply = self.send_query(&query, false, false).await?;
 
-        let res = scan_query(reply, "1850 00000000 %?%? %w %B%B%B%B".to_string())?;
+        let res = scan_query(reply, "1850 00000000 %?%? %w %B%B%B%B")?;
 
         let value = res[0].to_i64().unwrap();
 
@@ -808,23 +816,23 @@ impl NetMDInterface {
     /// Change track in a [`Direction`]
     pub async fn track_change(&mut self, direction: Direction) -> Result<(), InterfaceError> {
         let query = format_query(
-            "1850 ff10 00000000 %w".to_string(),
+            "1850 ff10 00000000 %w",
             vec![QueryValue::Number(direction as i64)],
         )
         .unwrap();
 
         let reply = self.send_query(&query, false, false).await?;
 
-        scan_query(reply, "1850 0010 00000000 %?%?".to_string())?;
+        scan_query(reply, "1850 0010 00000000 %?%?")?;
 
         Ok(())
     }
 
     /// Erase the disc entirely
     pub async fn erase_disc(&mut self) -> Result<(), InterfaceError> {
-        let query = format_query("1840 ff 0000".to_string(), vec![]).unwrap();
+        let query = format_query("1840 ff 0000", vec![]).unwrap();
         let reply = self.send_query(&query, false, false).await?;
-        scan_query(reply, "1840 00 0000".to_string())?;
+        scan_query(reply, "1840 00 0000")?;
         Ok(())
     }
 
@@ -835,11 +843,11 @@ impl NetMDInterface {
         self.change_descriptor_state(&Descriptor::RootTD, &DescriptorAction::OpenRead)
             .await?;
 
-        let query = format_query("1806 01101000 ff00 0001000b".to_string(), vec![]).unwrap();
+        let query = format_query("1806 01101000 ff00 0001000b", vec![]).unwrap();
 
         let reply = self.send_query(&query, false, false).await?;
 
-        let res = scan_query(reply, "1806 01101000 1000 0001000b %b".to_string()).unwrap();
+        let res = scan_query(reply, "1806 01101000 1000 0001000b %b").unwrap();
 
         self.change_descriptor_state(&Descriptor::RootTD, &DescriptorAction::Close)
             .await?;
@@ -853,13 +861,13 @@ impl NetMDInterface {
             .await?;
 
         let query =
-            format_query("1806 02101001 3000 1000 ff00 00000000".to_string(), vec![]).unwrap();
+            format_query("1806 02101001 3000 1000 ff00 00000000", vec![]).unwrap();
 
         let reply = self.send_query(&query, false, false).await?;
 
         let res = scan_query(
             reply,
-            "1806 02101001 %?%? %?%? 1000 00%?0000 0006 0010000200%b".to_string(),
+            "1806 02101001 %?%? %?%? 1000 00%?0000 0006 0010000200%b",
         )
         .unwrap();
 
@@ -890,7 +898,7 @@ impl NetMDInterface {
             };
 
             let query = format_query(
-                "1806 02201801 00%b 3000 0a00 ff00 %w%w".to_string(),
+                "1806 02201801 00%b 3000 0a00 ff00 %w%w",
                 vec![
                     QueryValue::Number(wchar_value),
                     QueryValue::Number(remaining as i64),
@@ -904,7 +912,7 @@ impl NetMDInterface {
             if remaining == 0 {
                 let res = scan_query(
                     reply,
-                    "1806 02201801 00%? 3000 0a00 1000 %w0000 %?%?000a %w %*".to_string(),
+                    "1806 02201801 00%? 3000 0a00 1000 %w0000 %?%?000a %w %*",
                 )?;
 
                 chunksize = res[0].to_i64().unwrap() as i32;
@@ -915,7 +923,7 @@ impl NetMDInterface {
             } else {
                 let res = scan_query(
                     reply,
-                    "1806 02201801 00%? 3000 0a00 1000 %w%?%? %*".to_string(),
+                    "1806 02201801 00%? 3000 0a00 1000 %w%?%? %*",
                 )?;
                 chunksize = res[0].to_i64().unwrap() as i32;
                 chunk = SHIFT_JIS.decode(&res[1].to_vec().unwrap()).0.into();
@@ -1073,7 +1081,7 @@ impl NetMDInterface {
         let mut track_titles: Vec<String> = vec![];
         for i in tracks {
             let query = format_query(
-                "1806 022018%b %w 3000 0a00 ff00 00000000".to_string(),
+                "1806 022018%b %w 3000 0a00 ff00 00000000",
                 vec![
                     QueryValue::Number(wchar_value),
                     QueryValue::Number(i as i64),
@@ -1085,7 +1093,7 @@ impl NetMDInterface {
 
             let res = scan_query(
                 reply,
-                "1806 022018%? %?%? %?%? %?%? 1000 00%?0000 00%?000a %x".to_string(),
+                "1806 022018%? %?%? %?%? %?%? 1000 00%?0000 00%?000a %x",
             )
             .unwrap();
 
@@ -1152,7 +1160,7 @@ impl NetMDInterface {
         }
 
         let query = format_query(
-            "1807 02201801 00%b 3000 0a00 5000 %w 0000 %w %*".to_string(),
+            "1807 02201801 00%b 3000 0a00 5000 %w 0000 %w %*",
             vec![
                 QueryValue::Number(wchar_value),
                 QueryValue::Number(new_len as i64),
@@ -1216,7 +1224,7 @@ impl NetMDInterface {
             .await?;
 
         let query = format_query(
-            "1807 022018%b %w 3000 0a00 5000 %w 0000 %w %*".to_string(),
+            "1807 022018%b %w 3000 0a00 5000 %w 0000 %w %*",
             vec![
                 QueryValue::Number(wchar_value),
                 QueryValue::Number(track as i64),
@@ -1229,7 +1237,7 @@ impl NetMDInterface {
 
         let _ = scan_query(
             reply,
-            "1807 022018%? %?%? 3000 0a00 5000 %?%? 0000 %?%?".to_string(),
+            "1807 022018%? %?%? 3000 0a00 5000 %?%? 0000 %?%?",
         );
         self.change_descriptor_state(&descriptor, &DescriptorAction::Close)
             .await?;
@@ -1240,7 +1248,7 @@ impl NetMDInterface {
     /// Erases a track from the disc's UTOC
     pub async fn erase_track(&mut self, track: u16) -> Result<(), InterfaceError> {
         let query = format_query(
-            "1840 ff01 00 201001 %w".to_string(),
+            "1840 ff01 00 201001 %w",
             vec![QueryValue::Number(track as i64)],
         )?;
 
@@ -1252,7 +1260,7 @@ impl NetMDInterface {
     /// Moves a track to another index on the disc
     pub async fn move_track(&mut self, source: u16, dest: u16) -> Result<(), InterfaceError> {
         let query = format_query(
-            "1843 ff00 00 201001 %w 201001 %w".to_string(),
+            "1843 ff00 00 201001 %w 201001 %w",
             vec![
                 QueryValue::Number(source as i64),
                 QueryValue::Number(dest as i64),
@@ -1275,7 +1283,7 @@ impl NetMDInterface {
             .await?;
 
         let query = format_query(
-            "1806 02201001 %w %w %w ff00 00000000".to_string(),
+            "1806 02201001 %w %w %w ff00 00000000",
             vec![
                 QueryValue::Number(track as i64),
                 QueryValue::Number(p1 as i64),
@@ -1286,7 +1294,7 @@ impl NetMDInterface {
         let reply = self.send_query(&query, false, false).await?;
         let res = scan_query(
             reply,
-            "1806 02201001 %?%? %?%? %?%? 1000 00%?0000 %x".to_string(),
+            "1806 02201001 %?%? %?%? %?%? 1000 00%?0000 %x",
         )?;
 
         self.change_descriptor_state(&Descriptor::AudioContentsTD, &DescriptorAction::Close)
@@ -1307,7 +1315,7 @@ impl NetMDInterface {
 
         for track in tracks {
             let query = format_query(
-                "1806 02201001 %w %w %w ff00 00000000".to_string(),
+                "1806 02201001 %w %w %w ff00 00000000",
                 vec![
                     QueryValue::Number(track as i64),
                     QueryValue::Number(0x3000),
@@ -1319,12 +1327,12 @@ impl NetMDInterface {
 
             let res = scan_query(
                 reply,
-                "1806 02201001 %?%? %?%? %?%? 1000 00%?0000 %x".to_string(),
+                "1806 02201001 %?%? %?%? %?%? 1000 00%?0000 %x",
             )?;
 
             let result = scan_query(
                 res[0].to_vec().unwrap(),
-                "01 0006 0000 %B %B %B %B".to_string(),
+                "01 0006 0000 %B %B %B %B",
             )?;
 
             let times_num: Vec<u64> = result
@@ -1357,7 +1365,7 @@ impl NetMDInterface {
         track_number: u16,
     ) -> Result<(Encoding, Channels), InterfaceError> {
         let raw_value = self.raw_track_info(track_number, 0x3080, 0x0700).await?;
-        let result = scan_query(raw_value, "07 0004 0110 %b %b".to_string())?;
+        let result = scan_query(raw_value, "07 0004 0110 %b %b")?;
 
         let encoding = match result[0].to_i64() {
             Ok(0x90) => Encoding::SP,
@@ -1383,12 +1391,12 @@ impl NetMDInterface {
             .await?;
 
         let query = format_query(
-            "1806 01201001 %w ff00 00010008".to_string(),
+            "1806 01201001 %w ff00 00010008",
             vec![QueryValue::Number(track as i64)],
         )?;
         let reply = self.send_query(&query, false, false).await?;
 
-        let res = scan_query(reply, "1806 01201001 %?%? 10 00 00010008 %b".to_string())?;
+        let res = scan_query(reply, "1806 01201001 %?%? 10 00 00010008 %b")?;
 
         self.change_descriptor_state(&Descriptor::AudioContentsTD, &DescriptorAction::Close)
             .await?;
@@ -1401,13 +1409,13 @@ impl NetMDInterface {
         self.change_descriptor_state(&Descriptor::RootTD, &DescriptorAction::OpenRead)
             .await?;
 
-        let query = format_query("1806 02101000 3080 0300 ff00 00000000".to_string(), vec![])?;
+        let query = format_query("1806 02101000 3080 0300 ff00 00000000", vec![])?;
         let reply = self.send_query(&query, false, false).await?;
 
         // 8003 changed to %?03 - Panasonic returns 0803 instead. This byte's meaning is unknown
         let res = scan_query(
             reply,
-            "1806 02101000 3080 0300 1000 001d0000 001b %?03 0017 8000 0005 %W %B %B %B 0005 %W %B %B %B 0005 %W %B %B %B".to_string()
+            "1806 02101000 3080 0300 1000 001d0000 001b %?03 0017 8000 0005 %W %B %B %B 0005 %W %B %B %B 0005 %W %B %B %B"
         )?;
 
         let res_num: Vec<RawTime> = res
@@ -1435,13 +1443,13 @@ impl NetMDInterface {
         .await?;
 
         let query = format_query(
-            "1809 8001 0330 8801 0030 8805 0030 8807 00 ff00 00000000".to_string(),
+            "1809 8001 0330 8801 0030 8805 0030 8807 00 ff00 00000000",
             vec![],
         )?;
 
         let reply = self.send_query(&query, false, false).await?;
 
-        let res = scan_query(reply, "1809 8001 0330 8801 0030 8805 0030 8807 00 1000 000e0000 000c 8805 0008 80e0 0110 %b %b 4000".to_string())?;
+        let res = scan_query(reply, "1809 8001 0330 8801 0030 8805 0030 8807 00 1000 000e0000 000c 8805 0008 80e0 0110 %b %b 4000")?;
 
         self.change_descriptor_state(&Descriptor::OperatingStatusBlock, &DescriptorAction::Close)
             .await?;
@@ -1458,7 +1466,7 @@ impl NetMDInterface {
         progress_callback: Option<F>,
     ) -> Result<(DiscFormat, u16, Vec<u8>), InterfaceError> {
         let query = format_query(
-            "1800 080046 f003010330 ff00 1001 %w".to_string(),
+            "1800 080046 f003010330 ff00 1001 %w",
             vec![QueryValue::Number((track + 1) as i64)],
         )?;
 
@@ -1466,7 +1474,7 @@ impl NetMDInterface {
 
         let res = scan_query(
             reply,
-            "1800 080046 f0030103 300000 1001 %w %b %d".to_string(),
+            "1800 080046 f0030103 300000 1001 %w %b %d",
         )?;
 
         let frames = res[0].to_i64().unwrap() as u16;
@@ -1480,7 +1488,7 @@ impl NetMDInterface {
 
         scan_query(
             self.read_reply(false).await?,
-            "1800 080046 f003010330 0000 1001 %?%? %?%?".to_string(),
+            "1800 080046 f003010330 0000 1001 %?%? %?%?",
         )?;
 
         cross_sleep(Duration::from_millis(500)).await;
@@ -1498,28 +1506,28 @@ impl NetMDInterface {
 
     pub async fn disable_new_track_protection(&mut self, val: u16) -> Result<(), InterfaceError> {
         let query = format_query(
-            "1800 080046 f0030103 2b ff %w".to_string(),
+            "1800 080046 f0030103 2b ff %w",
             vec![QueryValue::Number(val as i64)],
         )?;
 
         let reply = self.send_query(&query, false, false).await?;
-        scan_query(reply, "1800 080046 f0030103 2b 00 %?%?".to_string())?;
+        scan_query(reply, "1800 080046 f0030103 2b 00 %?%?")?;
         Ok(())
     }
 
     pub async fn enter_secure_session(&mut self) -> Result<(), InterfaceError> {
-        let query = format_query("1800 080046 f0030103 80 ff".to_string(), vec![])?;
+        let query = format_query("1800 080046 f0030103 80 ff", vec![])?;
 
         let reply = self.send_query(&query, false, false).await?;
-        scan_query(reply, "1800 080046 f0030103 80 00".to_string())?;
+        scan_query(reply, "1800 080046 f0030103 80 00")?;
         Ok(())
     }
 
     pub async fn leave_secure_session(&mut self) -> Result<(), InterfaceError> {
-        let query = format_query("1800 080046 f0030103 81 ff".to_string(), vec![])?;
+        let query = format_query("1800 080046 f0030103 81 ff", vec![])?;
 
         let reply = self.send_query(&query, false, false).await?;
-        scan_query(reply, "1800 080046 f0030103 81 00".to_string())?;
+        scan_query(reply, "1800 080046 f0030103 81 00")?;
         Ok(())
     }
 
@@ -1530,10 +1538,10 @@ impl NetMDInterface {
     ///
     /// The leaf ID is a 8-byte constant
     pub async fn leaf_id(&mut self) -> Result<[u8; 8], InterfaceError> {
-        let query = format_query("1800 080046 f0030103 11 ff".to_string(), vec![])?;
+        let query = format_query("1800 080046 f0030103 11 ff", vec![])?;
 
         let reply = self.send_query(&query, false, false).await?;
-        let res = scan_query(reply, "1800 080046 f0030103 11 00 %*".to_string())?;
+        let res = scan_query(reply, "1800 080046 f0030103 11 00 %*")?;
 
         Ok(res[0].to_vec().unwrap().try_into().unwrap())
     }
@@ -1555,7 +1563,7 @@ impl NetMDInterface {
         let keychains = keychain.concat();
 
         let query = format_query(
-            "1800 080046 f0030103 12 ff %w 0000 %w %d %d %d 00000000 %* %*".to_string(),
+            "1800 080046 f0030103 12 ff %w 0000 %w %d %d %d 00000000 %* %*",
             vec![
                 QueryValue::Number(databytes as i64),
                 QueryValue::Number(databytes as i64),
@@ -1571,7 +1579,7 @@ impl NetMDInterface {
 
         scan_query(
             reply,
-            "1800 080046 f0030103 12 01 %?%? %?%?%?%?".to_string(),
+            "1800 080046 f0030103 12 01 %?%? %?%?%?%?",
         )?;
 
         Ok(())
@@ -1589,22 +1597,22 @@ impl NetMDInterface {
         }
 
         let query = format_query(
-            "1800 080046 f0030103 20 ff 000000 %*".to_string(),
+            "1800 080046 f0030103 20 ff 000000 %*",
             vec![QueryValue::Array(hostnonce)],
         )?;
 
         let reply = self.send_query(&query, false, false).await?;
 
-        let res = scan_query(reply, "1800 080046 f0030103 20 %? 000000 %#".to_string())?;
+        let res = scan_query(reply, "1800 080046 f0030103 20 %? 000000 %#")?;
 
         Ok(res[0].to_vec().unwrap())
     }
 
     pub async fn session_key_forget(&mut self) -> Result<(), InterfaceError> {
-        let query = format_query("1800 080046 f0030103 21 ff 000000".to_string(), vec![])?;
+        let query = format_query("1800 080046 f0030103 21 ff 000000", vec![])?;
 
         let reply = self.send_query(&query, false, false).await?;
-        let _ = scan_query(reply, "1800 080046 f0030103 21 00 000000".to_string())?;
+        let _ = scan_query(reply, "1800 080046 f0030103 21 00 000000")?;
 
         Ok(())
     }
@@ -1640,13 +1648,13 @@ impl NetMDInterface {
             .unwrap();
 
         let query = format_query(
-            "1800 080046 f0030103 22 ff 0000 %*".to_string(),
+            "1800 080046 f0030103 22 ff 0000 %*",
             vec![QueryValue::Array(message)],
         )?;
 
         let reply = self.send_query(&query, false, false).await?;
 
-        scan_query(reply, "1800 080046 f0030103 22 00 0000".to_string())?;
+        scan_query(reply, "1800 080046 f0030103 22 00 0000")?;
 
         Ok(())
     }
@@ -1669,7 +1677,7 @@ impl NetMDInterface {
             .unwrap();
 
         let query = format_query(
-            "1800 080046 f0030103 48 ff 00 1001 %w %*".to_string(),
+            "1800 080046 f0030103 48 ff 00 1001 %w %*",
             vec![
                 QueryValue::Number(track_number as i64),
                 QueryValue::Array(Vec::from(message)),
@@ -1678,7 +1686,7 @@ impl NetMDInterface {
 
         let reply = self.send_query(&query, false, false).await?;
 
-        scan_query(reply, "1800 080046 f0030103 48 00 00 1001 %?%?".to_string())?;
+        scan_query(reply, "1800 080046 f0030103 48 00 00 1001 %?%?")?;
 
         Ok(())
     }
@@ -1708,7 +1716,7 @@ impl NetMDInterface {
         let total_bytes: usize = (pkt_size + 24) as usize; //framesizedict[wireformat] * frames + pktcount * 24;
 
         let query = format_query(
-            "1800 080046 f0030103 28 ff 000100 1001 ffff 00 %b %b %d %d".to_string(),
+            "1800 080046 f0030103 28 ff 000100 1001 ffff 00 %b %b %d %d",
             vec![
                 QueryValue::Number(wireformat as i64),
                 QueryValue::Number(discformat as i64),
@@ -1719,7 +1727,7 @@ impl NetMDInterface {
         let mut reply = self.send_query(&query, false, true).await?;
         scan_query(
             reply,
-            "1800 080046 f0030103 28 00 000100 1001 %?%? 00 %*".to_string(),
+            "1800 080046 f0030103 28 00 000100 1001 %?%? 00 %*",
         )?;
         self.device.poll().await?;
 
@@ -1750,7 +1758,7 @@ impl NetMDInterface {
         self.device.poll().await?;
         let res = scan_query(
             reply,
-            "1800 080046 f0030103 28 00 000100 1001 %w 00 %?%? %?%?%?%? %?%?%?%? %*".to_string(),
+            "1800 080046 f0030103 28 00 000100 1001 %w 00 %?%? %?%?%?%? %?%?%?%? %*",
         )?;
 
         let mut encrypted_data = res[1].to_vec().unwrap();
@@ -1766,18 +1774,18 @@ impl NetMDInterface {
 
     pub async fn track_uuid(&mut self, track: u16) -> Result<String, InterfaceError> {
         let query = format_query(
-            "1800 080046 f0030103 23 ff 1001 %w".to_string(),
+            "1800 080046 f0030103 23 ff 1001 %w",
             vec![QueryValue::Number(track as i64)],
         )?;
         let reply = self.send_query(&query, false, false).await?;
 
-        let res = scan_query(reply, "1800 080046 f0030103 23 00 1001 %?%? %*".to_string())?;
+        let res = scan_query(reply, "1800 080046 f0030103 23 00 1001 %?%? %*")?;
 
         Ok(String::from_utf8_lossy(&res[0].to_vec().unwrap()).to_string())
     }
 
     pub async fn terminate(&mut self) -> Result<(), InterfaceError> {
-        let query = format_query("1800 080046 f0030103 2a ff00".to_string(), vec![])?;
+        let query = format_query("1800 080046 f0030103 2a ff00", vec![])?;
         self.send_query(&query, false, false).await?;
 
         Ok(())
diff --git a/src/netmd/mod.rs b/src/netmd/mod.rs
index 5987e1d..e6aab9b 100644
--- a/src/netmd/mod.rs
+++ b/src/netmd/mod.rs
@@ -9,6 +9,11 @@ mod mappings;
 mod query_utils;
 mod utils;
 
+mod factory {
+    pub mod factory_interface;
+    pub mod factory_commands;
+}
+
 #[doc(inline)]
 pub use base::DEVICE_IDS_CROSSUSB;
 
diff --git a/src/netmd/query_utils.rs b/src/netmd/query_utils.rs
index c237c98..b032fb0 100644
--- a/src/netmd/query_utils.rs
+++ b/src/netmd/query_utils.rs
@@ -103,7 +103,7 @@ pub enum QueryError {
 }
 
 /// Formats a query using a standard input to send to the player
-pub fn format_query(format: String, args: Vec<QueryValue>) -> Result<Vec<u8>, QueryError> {
+pub fn format_query(format: &'static str, args: Vec<QueryValue>) -> Result<Vec<u8>, QueryError> {
     if DEBUG {
         println!("SENT>>> F: {}", format);
     }
@@ -198,7 +198,7 @@ pub fn format_query(format: String, args: Vec<QueryValue>) -> Result<Vec<u8>, Qu
 }
 
 /// Scans a result using a standard input to recieve from the player
-pub fn scan_query(query_result: Vec<u8>, format: String) -> Result<Vec<QueryValue>, QueryError> {
+pub fn scan_query(query_result: Vec<u8>, format: &'static str) -> Result<Vec<QueryValue>, QueryError> {
     if DEBUG {
         println!("RECV<<< F: {}", format);
     }
@@ -312,7 +312,7 @@ pub fn scan_query(query_result: Vec<u8>, format: String) -> Result<Vec<QueryValu
                     index: i,
                     expected: format_value,
                     actual: input_value,
-                    format_string: format,
+                    format_string: format.to_string(),
                 });
             }
             half = None;