8129965345

Committed 03 Mar 2024 11:58AM UTC coverage: 98.854% (+0.07%) from 98.788%

Build # 8129965345

Build Type

push

github

Committed by

web-flow

Commit Message

feat(preprocessor): implement the serde feature (#179)

Now, we are able to serialize/deserialize the command enum.

Run Details

1466 of 1483 relevant lines covered (98.85%)

60.85 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

99.33

/engine/preprocessor/src/lib.rs

#![deny(missing_docs)]
//! Preprocess keyboard events for an input method.
//!
//! Enables the generation of keyboard event responses from a keyboard input event in an input method
//! engine.
//! The `afrim-preprocessor` crate is built on the top of the [`afrim-memory`](afrim_memory) crate.
//!
//! # Example
//!
//! ```
//! use afrim_preprocessor::{utils, Command, Preprocessor};
//! use keyboard_types::{
//!     webdriver::{self, Event},
//!     Key::*,
//! };
//! use std::{collections::VecDeque, rc::Rc};
//!
//! // Prepares the memory.
//! let data = utils::load_data("cc ç");
//! let text_buffer = utils::build_map(data);
//! let memory = Rc::new(text_buffer);
//!
//! // Builds the preprocessor.
//! let mut preprocessor = Preprocessor::new(memory, 8);
//!
//! // Process an input.
//! let input = "cc";
//! webdriver::send_keys(input)
//!     .into_iter()
//!     .for_each(|event| {
//!         match event {
//!             // Triggers the generated keyboard input event.
//!             Event::Keyboard(event) => preprocessor.process(event),
//!             _ => unimplemented!(),
//!         };
//!     });
//!
//! // Now let's look at the generated commands.
//! // The expected results without `inhibit` feature.
//! #[cfg(not(feature = "inhibit"))]
//! let mut expecteds = VecDeque::from(vec![
//!     Command::Pause,
//!     Command::Delete,
//!     Command::Delete,
//!     Command::CommitText("ç".to_owned()),
//!     Command::Resume,
//! ]);
//!
//! // The expected results with `inhibit` feature.
//! #[cfg(feature = "inhibit")]
//! let mut expecteds = VecDeque::from(vec![
//!     Command::Pause,
//!     Command::Delete,
//!     Command::Resume,
//!     Command::Pause,
//!     Command::Delete,
//!     Command::CommitText("ç".to_owned()),
//!     Command::Resume,
//! ]);
//!
//! // Verification.
//! while let Some(command) = preprocessor.pop_queue() {
//!     assert_eq!(command, expecteds.pop_front().unwrap());
//! }
//! ```
//! **Note**: When dealing with non latin languages. The inhibit feature permit to remove as possible
//! the non wanted characters (generally, latin characters).

mod message;

pub use crate::message::Command;
pub use afrim_memory::utils;
use afrim_memory::{Cursor, Node};
pub use keyboard_types::{Key, KeyState, KeyboardEvent};
use std::{collections::VecDeque, rc::Rc};

/// The main structure of the preprocessor.
#[derive(Debug)]
pub struct Preprocessor {
    cursor: Cursor,
    queue: VecDeque<Command>,
}

impl Preprocessor {
    /// Initializes a new preprocessor.
    ///
    /// The preprocessor needs a memory to operate. You have two options to build this memory.
    /// - Use the [`afrim-memory`](afrim_memory) crate.
    /// - Use the [`utils`](crate::utils) module.
    /// It also needs you set the capacity of his cursor. We recommend to set a capacity equal
    /// or greater than N times the maximun sequence length that you want to handle.
    /// Where N is the number of sequences that you want track in the cursor.
    ///
    /// Note that the cursor is the internal memory of the `afrim_preprocessor`.
    ///
    /// # Example
    ///
    /// ```
    /// use afrim_preprocessor::{Preprocessor, utils};
    /// use std::rc::Rc;
    ///
    /// // We prepare the memory.
    /// let data = utils::load_data("uuaf3    ʉ̄ɑ̄");
    /// let text_buffer = utils::build_map(data);
    /// let memory = Rc::new(text_buffer);
    ///
    /// // We initialize our preprocessor.
    /// let preprocessor = Preprocessor::new(memory, 8);
    /// ```
    pub fn new(memory: Rc<Node>, buffer_size: usize) -> Self {
        let cursor = Cursor::new(memory, buffer_size);
        let queue = VecDeque::with_capacity(15);

        Self { cursor, queue }
    }

    // Cancel the previous operation.
    fn rollback(&mut self) -> bool {
        if let Some(out) = self.cursor.undo() {
            #[cfg(feature = "inhibit")]
            let start = 0;
            #[cfg(not(feature = "inhibit"))]
            let start = 1;
            let end = out.chars().count();

            (start..end).for_each(|_| self.queue.push_back(Command::Delete));

            // Clear the remaining code
            while let (None, 1.., ..) = self.cursor.state() {
                self.cursor.undo();
            }

            if let (Some(_in), ..) = self.cursor.state() {
                self.queue.push_back(Command::CommitText(_in));
            }

            true
        } else {
            false
        }
    }

    // Cancel the previous operation.
    //
    // Note that it handles the delete by itself.
    #[cfg(not(feature = "inhibit"))]
    fn hard_rollback(&mut self) -> bool {
        self.queue.push_back(Command::Delete);
        self.rollback()
    }

    // Cancel the previous opeartion.
    //
    // Note that the delete is supposed already executed.
    fn soft_rollback(&mut self) -> bool {
        self.queue.push_back(Command::CleanDelete);
        self.rollback()
    }

    /// Preprocess the keyboard input event and returns infos on his internal changes (change on
    /// the cursor and/or something to commit).
    ///
    /// It's useful when you process keyboard input events in bulk. Whether there is something that
    /// you want to do based on this information, you can decide how to continue.
    ///
    /// # Example
    ///
    /// ```
    /// use afrim_preprocessor::{Command, Preprocessor, utils};
    /// use keyboard_types::{Key::*, KeyboardEvent};
    /// use std::{collections::VecDeque, rc::Rc};
    ///
    /// // We prepare the memory.
    /// let data = utils::load_data("i3  ī");
    /// let text_buffer = utils::build_map(data);
    /// let memory = Rc::new(text_buffer);
    ///
    /// let mut preprocessor = Preprocessor::new(memory, 8);
    ///
    /// // We process the input.
    /// // let input = "si3";
    ///
    /// let info = preprocessor.process(KeyboardEvent {
    ///     key: Character("s".to_string()),
    ///     ..Default::default()
    /// });
    /// assert_eq!(info, (true, false));
    ///
    /// let info = preprocessor.process(KeyboardEvent {
    ///     key: Character("i".to_string()),
    ///     ..Default::default()
    /// });
    /// assert_eq!(info, (true, false));
    ///
    /// let info = preprocessor.process(KeyboardEvent {
    ///     key: Character("3".to_string()),
    ///     ..Default::default()
    /// });
    /// assert_eq!(info, (true, true));
    ///
    /// // The input inside the preprocessor.
    /// assert_eq!(preprocessor.get_input(), "si3".to_owned());
    ///
    /// // The generated commands.
    /// // The expected results without inhibit feature.
    /// #[cfg(not(feature = "inhibit"))]
    /// let mut expecteds = VecDeque::from(vec![
    ///     Command::Pause,
    ///     Command::Delete,
    ///     Command::Delete,
    ///     Command::CommitText("ī".to_owned()),
    ///     Command::Resume,
    /// ]);
    ///
    /// // The expected results with inhibit feature.
    /// #[cfg(feature = "inhibit")]
    /// let mut expecteds = VecDeque::from(vec![
    ///     Command::Pause,
    ///     Command::Delete,
    ///     Command::Resume,
    ///     Command::Pause,
    ///     Command::Delete,
    ///     Command::Resume,
    ///     Command::Pause,
    ///     Command::Delete,
    ///     Command::CommitText("ī".to_owned()),
    ///     Command::Resume,
    /// ]);
    ///
    /// // Verification.
    /// while let Some(command) = preprocessor.pop_queue() {
    ///     dbg!(command.clone());
    ///     assert_eq!(command, expecteds.pop_front().unwrap());
    /// }
    /// ```
    pub fn process(&mut self, event: KeyboardEvent) -> (bool, bool) {
        let (mut changed, mut committed) = (false, false);

        match (event.state, event.key) {
            (KeyState::Down, Key::Backspace) => {
                #[cfg(not(feature = "inhibit"))]
                {
                    self.pause();
                    committed = self.soft_rollback();
                    self.resume();
                }
                #[cfg(feature = "inhibit")]
                self.cursor.clear();
                changed = true;
            }
            (KeyState::Down, Key::Character(character))
                if character
                    .chars()
                    .next()
                    .map(|e| e.is_alphanumeric() || e.is_ascii_punctuation())
                    .unwrap_or(false) =>
            {
                #[cfg(feature = "inhibit")]
                self.pause();
                #[cfg(feature = "inhibit")]
                self.queue.push_back(Command::Delete);

                let character = character.chars().next().unwrap();

                if let Some(_in) = self.cursor.hit(character) {
                    #[cfg(not(feature = "inhibit"))]
                    self.pause();
                    let mut prev_cursor = self.cursor.clone();
                    prev_cursor.undo();
                    #[cfg(not(feature = "inhibit"))]
                    self.queue.push_back(Command::Delete);

                    // Remove the remaining code
                    while let (None, 1.., ..) = prev_cursor.state() {
                        prev_cursor.undo();
                        #[cfg(not(feature = "inhibit"))]
                        self.queue.push_back(Command::Delete);
                    }

                    if let (Some(out), ..) = prev_cursor.state() {
                        (0..out.chars().count()).for_each(|_| self.queue.push_back(Command::Delete))
                    }

                    self.queue.push_back(Command::CommitText(_in));
                    #[cfg(not(feature = "inhibit"))]
                    self.resume();
                    committed = true;
                };

                #[cfg(feature = "inhibit")]
                self.resume();
                changed = true;
            }
            (KeyState::Down, Key::Shift | Key::CapsLock) => (),
            (KeyState::Down, _) => {
                self.cursor.clear();
                changed = true;
            }
            _ => (),
        };

        (changed, committed)
    }

    /// Commit a text.
    ///
    /// Generate a command to ensure the commitment of this text.
    /// Useful when you want deal with auto-completion.
    ///
    /// **Note**: Before any commitment, the preprocessor make sure to discard the current input.
    ///
    /// # Example
    ///
    /// ```
    /// use afrim_preprocessor::{Command, Preprocessor, utils};
    /// use keyboard_types::{Key::*, KeyboardEvent};
    /// use std::{collections::VecDeque, rc::Rc};
    ///
    /// // We prepare the memory.
    /// let data = utils::load_data("i3  ī");
    /// let text_buffer = utils::build_map(data);
    /// let memory = Rc::new(text_buffer);
    ///
    /// let mut preprocessor = Preprocessor::new(memory, 8);
    ///
    /// // We process the input.
    /// // let input = "si3";
    /// preprocessor.process(KeyboardEvent {
    ///     key: Character("s".to_string()),
    ///     ..Default::default()
    /// });
    ///
    /// preprocessor.commit("sī");
    ///
    /// // The generated commands.
    /// // The expected results without inhibit feature.
    /// #[cfg(not(feature = "inhibit"))]
    /// let mut expecteds = VecDeque::from(vec![
    ///     Command::Pause,
    ///     Command::Delete,
    ///     Command::CommitText("sī".to_owned()),
    ///     Command::Resume,
    /// ]);
    ///
    /// // The expected results with inhibit feature.
    /// #[cfg(feature = "inhibit")]
    /// let mut expecteds = VecDeque::from(vec![
    ///     Command::Pause,
    ///     Command::Delete,
    ///     Command::Resume,
    ///     Command::Pause,
    ///     Command::CleanDelete,
    ///     Command::CommitText("sī".to_owned()),
    ///     Command::Resume,
    /// ]);
    ///
    /// // Verification.
    /// while let Some(command) = preprocessor.pop_queue() {
    ///     assert_eq!(command, expecteds.pop_front().unwrap());
    /// }
    /// ```
    pub fn commit(&mut self, text: &str) {
        self.pause();

        while !self.cursor.is_empty() {
            #[cfg(not(feature = "inhibit"))]
            self.hard_rollback();
            #[cfg(feature = "inhibit")]
            self.soft_rollback();
        }
        #[cfg(feature = "inhibit")]
        self.cursor.clear();
        self.queue.push_back(Command::CommitText(text.to_owned()));
        self.resume();
        // We clear the buffer
        self.cursor.clear();
    }

    // Pauses the keyboard event listerner.
    fn pause(&mut self) {
        self.queue.push_back(Command::Pause);
    }

    // Resumes the keyboard event listener.
    fn resume(&mut self) {
        self.queue.push_back(Command::Resume);
    }

    /// Returns the input present in the internal memory.
    ///
    /// It's always useful to know what is inside the memory of the preprocessor for debugging.
    /// **Note**: The input inside the preprocessor is not always the same than the original because
    /// of the limited capacity of his internal cursor.
    ///
    /// # Example
    ///
    /// ```
    /// use afrim_preprocessor::{Command, Preprocessor, utils};
    /// use keyboard_types::{Key::*, webdriver::{self, Event}};
    /// use std::{collections::VecDeque, rc::Rc};
    ///
    /// // We prepare the memory.
    /// let data = utils::load_data("i3  ī");
    /// let text_buffer = utils::build_map(data);
    /// let memory = Rc::new(text_buffer);
    ///
    /// let mut preprocessor = Preprocessor::new(memory, 4);
    ///
    /// // We process the input.
    /// let input = "si3";
    /// webdriver::send_keys(input)
    ///     .into_iter()
    ///     .for_each(|event| {
    ///         match event {
    ///             // Triggers the generated keyboard input event.
    ///             Event::Keyboard(event) => preprocessor.process(event),
    ///             _ => unimplemented!(),
    ///         };
    ///     });
    ///
    /// // The input inside the processor.
    /// assert_eq!(preprocessor.get_input(), "si3".to_owned());
    pub fn get_input(&self) -> String {
        self.cursor
            .to_sequence()
            .into_iter()
            .filter(|c| *c != '\0')
            .collect::<String>()
    }

    /// Returns the next command to be executed.
    ///
    /// The next command is dropped from the queue and can't be returned anymore.
    ///
    /// # Example
    ///
    /// ```
    /// use afrim_preprocessor::{Command, Preprocessor, utils};
    /// use std::{collections::VecDeque, rc::Rc};
    ///
    /// // We prepare the memory.
    /// let text_buffer = utils::build_map(vec![]);
    /// let memory = Rc::new(text_buffer);
    ///
    /// let mut preprocessor = Preprocessor::new(memory, 8);
    /// preprocessor.commit("hello");
    ///
    /// // The expected results.
    /// let mut expecteds = VecDeque::from(vec![
    ///     Command::Pause,
    ///     Command::CommitText("hello".to_owned()),
    ///     Command::Resume,
    /// ]);
    ///
    /// // Verification.
    /// while let Some(command) = preprocessor.pop_queue() {
    ///     assert_eq!(command, expecteds.pop_front().unwrap());
    /// }
    pub fn pop_queue(&mut self) -> Option<Command> {
        self.queue.pop_front()
    }

    /// Clears the queue.
    ///
    /// # Example
    ///
    /// ```
    /// use afrim_preprocessor::{Preprocessor, utils};
    /// use std::rc::Rc;
    ///
    /// let data =
    /// utils::load_data("n* ŋ");
    /// let text_buffer = utils::build_map(data);
    /// let memory = Rc::new(text_buffer);
    ///
    /// let mut preprocessor = Preprocessor::new(memory, 8);
    /// preprocessor.commit("hi");
    /// preprocessor.clear_queue();
    ///
    /// assert_eq!(preprocessor.pop_queue(), None);
    /// ```
    pub fn clear_queue(&mut self) {
        self.queue.clear();
    }
}

#[cfg(test)]
mod tests {
    use crate::message::Command;
    use crate::utils;
    use crate::Preprocessor;
    use keyboard_types::{
        webdriver::{self, Event},
        Key::*,
    };
    use std::collections::VecDeque;

    #[test]
    fn test_process() {
        use std::rc::Rc;

        let data = utils::load_data("ccced ç\ncc ç");
        let memory = utils::build_map(data);
        let mut preprocessor = Preprocessor::new(Rc::new(memory), 8);
        webdriver::send_keys("ccced").into_iter().for_each(|e| {
            match e {
                Event::Keyboard(e) => preprocessor.process(e),
                _ => unimplemented!(),
            };
        });
        let mut expecteds = VecDeque::from(vec![
            // c c
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::CommitText("ç".to_owned()),
            Command::Resume,
            // c e d
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::Delete,
            Command::CommitText("ç".to_owned()),
            Command::Resume,
        ]);

        while let Some(command) = preprocessor.pop_queue() {
            assert_eq!(command, expecteds.pop_front().unwrap());
        }
    }

    #[test]
    fn test_commit() {
        use afrim_memory::Node;
        use keyboard_types::KeyboardEvent;

        let mut preprocessor = Preprocessor::new(Node::default().into(), 8);
        preprocessor.process(KeyboardEvent {
            key: Character("a".to_owned()),
            ..Default::default()
        });
        preprocessor.commit("word");

        let mut expecteds = VecDeque::from(vec![
            Command::Pause,
            #[cfg(feature = "inhibit")]
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            #[cfg(feature = "inhibit")]
            Command::CleanDelete,
            #[cfg(not(feature = "inhibit"))]
            Command::Delete,
            Command::CommitText("word".to_owned()),
            Command::Resume,
        ]);

        while let Some(command) = preprocessor.pop_queue() {
            assert_eq!(command, expecteds.pop_front().unwrap());
        }
    }

    #[test]
    fn test_rollback() {
        use keyboard_types::KeyboardEvent;
        use std::rc::Rc;

        let data = utils::load_data("ccced ç\ncc ç");
        let memory = utils::build_map(data);
        let mut preprocessor = Preprocessor::new(Rc::new(memory), 8);
        let backspace_event = KeyboardEvent {
            key: Backspace,
            ..Default::default()
        };

        webdriver::send_keys("ccced").into_iter().for_each(|e| {
            match e {
                Event::Keyboard(e) => preprocessor.process(e),
                _ => unimplemented!(),
            };
        });

        preprocessor.clear_queue();
        assert_eq!(preprocessor.get_input(), "ccced".to_owned());
        preprocessor.process(backspace_event.clone());
        #[cfg(not(feature = "inhibit"))]
        assert_eq!(preprocessor.get_input(), "cc".to_owned());
        #[cfg(not(feature = "inhibit"))]
        preprocessor.process(backspace_event);
        assert_eq!(preprocessor.get_input(), "".to_owned());

        let mut expecteds = VecDeque::from(vec![
            Command::Pause,
            #[cfg(not(feature = "inhibit"))]
            Command::CleanDelete,
            Command::CommitText("ç".to_owned()),
            Command::Resume,
            #[cfg(not(feature = "inhibit"))]
            Command::Pause,
            #[cfg(not(feature = "inhibit"))]
            Command::CleanDelete,
            #[cfg(not(feature = "inhibit"))]
            Command::Resume,
        ]);

        while let Some(command) = preprocessor.pop_queue() {
            assert_eq!(command, expecteds.pop_front().unwrap());
        }
    }

    #[test]
    fn test_advanced() {
        use std::{fs, rc::Rc};

        let data = fs::read_to_string("./data/sample.txt").unwrap();
        let data = utils::load_data(&data);
        let memory = utils::build_map(data);
        let mut preprocessor = Preprocessor::new(Rc::new(memory), 64);

        webdriver::send_keys(
            "u\u{E003}uu\u{E003}uc_ceduuaf3afafaff3uu3\
            \u{E003}\u{E003}\u{E003}\u{E003}\u{E003}\u{E003}\u{E003}\u{E003}\u{E003}\u{E003}\u{E003}\u{E003}"
        ).into_iter().for_each(|e| {
            match e {
                Event::Keyboard(e) => preprocessor.process(e),
                _ => unimplemented!(),
            };
        });

        let mut expecteds = VecDeque::from(vec![
            // Process
            // u backspace
            Command::Pause,
            #[cfg(feature = "inhibit")]
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(not(feature = "inhibit"))]
            Command::CleanDelete,
            #[cfg(not(feature = "inhibit"))]
            Command::Resume,
            // u u backspace
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::CommitText("ʉ".to_owned()),
            Command::Resume,
            #[cfg(not(feature = "inhibit"))]
            Command::Pause,
            #[cfg(not(feature = "inhibit"))]
            Command::CleanDelete,
            #[cfg(not(feature = "inhibit"))]
            Command::Resume,
            // u
            #[cfg(feature = "inhibit")]
            Command::Pause,
            #[cfg(feature = "inhibit")]
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            // c _
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::CommitText("ç".to_owned()),
            Command::Resume,
            // c e d
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::Delete,
            Command::CommitText("ç".to_owned()),
            Command::Resume,
            // u u
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::CommitText("ʉ".to_owned()),
            Command::Resume,
            // a f 3
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::Delete,
            Command::CommitText("ʉ\u{304}ɑ\u{304}".to_owned()),
            Command::Resume,
            // a f
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::CommitText("ɑ".to_owned()),
            Command::Resume,
            // a f
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::CommitText("ɑ".to_owned()),
            Command::Resume,
            // a f
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::CommitText("ɑ".to_owned()),
            Command::Resume,
            // f
            Command::Pause,
            Command::Delete,
            Command::Delete,
            Command::CommitText("ɑɑ".to_owned()),
            Command::Resume,
            // 3
            Command::Pause,
            Command::Delete,
            Command::Delete,
            Command::Delete,
            Command::CommitText("ɑ\u{304}ɑ\u{304}".to_owned()),
            Command::Resume,
            // uu
            Command::Pause,
            Command::Delete,
            #[cfg(feature = "inhibit")]
            Command::Resume,
            #[cfg(feature = "inhibit")]
            Command::Pause,
            Command::Delete,
            Command::CommitText("ʉ".to_owned()),
            Command::Resume,
            // 3
            Command::Pause,
            Command::Delete,
            Command::Delete,
            Command::CommitText("ʉ\u{304}".to_owned()),
            Command::Resume,
            // Rollback
            Command::Pause,
            Command::CleanDelete,
            Command::Delete,
            Command::CommitText("ʉ".to_owned()),
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Delete,
            Command::Delete,
            Command::Delete,
            Command::CommitText("ɑɑ".to_owned()),
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Delete,
            Command::CommitText("ɑ".to_owned()),
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Delete,
            Command::Delete,
            Command::Delete,
            Command::CommitText("ʉ".to_owned()),
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::CommitText("ç".to_owned()),
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Resume,
            Command::Pause,
            Command::CleanDelete,
            Command::Resume,
        ]);

        while let Some(command) = preprocessor.pop_queue() {
            assert_eq!(command, expecteds.pop_front().unwrap());
        }
    }
}

pythonbrad / afrim / 8129965345

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous