smart_keymap_core/key/

automation.rs

use core::fmt::Debug;
use core::ops::Index;

use serde::Deserialize;

use crate::input;
use crate::key;

const EXECUTION_QUEUE_SIZE: usize = 8;

/// Reference for a automation key.
#[derive(Deserialize, Debug, Clone, Copy, PartialEq)]
pub struct Ref(pub u8);

/// Value describing an automation key execution.
#[derive(Deserialize, Debug, Clone, Copy, PartialEq)]
pub struct Execution {
    /// The start index into the instructions array.
    pub start: u16,
    /// The number of instructions to execute.
    pub length: u16,
}

impl Execution {
    /// An empty execution.
    pub const EMPTY: Self = Self {
        start: 0,
        length: 0,
    };

    /// Returns true if the execution is empty (length == 0).
    pub const fn is_empty(&self) -> bool {
        self.length == 0
    }

    /// Increments the execution to the next instruction.
    pub fn incr(&mut self) {
        if self.length > 0 {
            self.start += 1;
            self.length -= 1;
        }
    }
}

/// Instructions for a automation key.
#[derive(Deserialize, Debug, Clone, Copy, PartialEq)]
pub struct KeyInstructions {
    /// The automation instructions to execute when the key is pressed.
    pub on_press: Execution,
    /// The automation instructions to execute while the key is pressed.
    pub while_pressed: Execution,
    /// The automation instructions to execute when the key is released.
    pub on_release: Execution,
}

/// Definition for a automation key.
#[derive(Deserialize, Debug, Clone, Copy, PartialEq)]
pub struct Key {
    /// The automation instructions for the key.
    pub automation_instructions: KeyInstructions,
}

/// An instruction for a automation key.
#[derive(Deserialize, Debug, Default, Clone, Copy, PartialEq)]
pub enum Instruction {
    /// No operation.
    #[default]
    NoOp,
    /// Press a key.
    Press(key::KeyOutput),
    /// Release a key.
    Release(key::KeyOutput),
    /// Taps a key.
    Tap(key::KeyOutput),
    /// Wait for a number of ticks.
    Wait(u16),
}

/// Config for automation keys.
#[derive(Deserialize, Clone, Copy, PartialEq)]
pub struct Config<const INSTRUCTION_COUNT: usize> {
    /// Concatenation of all the automation key instructions.
    ///
    /// Automation keys' instructions are defined by start+len into this array.
    #[serde(deserialize_with = "deserialize_instructions")]
    pub instructions: [Instruction; INSTRUCTION_COUNT],

    /// Duration (in ticks) of each instruction.
    #[serde(default = "default_instruction_duration")]
    pub instruction_duration: u16,
}

struct InstructionsDebugHelper<'a, const INSTRUCTION_COUNT: usize> {
    instructions: &'a [Instruction; INSTRUCTION_COUNT],
}

impl<'a, const INSTRUCTION_COUNT: usize> core::fmt::Debug
    for InstructionsDebugHelper<'a, INSTRUCTION_COUNT>
{
    fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
        // Reverse-find the last non-NoOp instruction to avoid printing large arrays.
        let last_non_noop_inst_pos = self
            .instructions
            .iter()
            .rposition(|inst| *inst != Instruction::NoOp)
            .map_or(0, |pos| pos + 1);
        if last_non_noop_inst_pos < INSTRUCTION_COUNT {
            f.debug_list()
                .entries(&self.instructions[..last_non_noop_inst_pos])
                .finish_non_exhaustive()
        } else {
            f.debug_list().entries(&self.instructions[..]).finish()
        }
    }
}

impl<const INSTRUCTION_COUNT: usize> core::fmt::Debug for Config<INSTRUCTION_COUNT> {
    fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
        f.debug_struct("Config")
            .field(
                "instructions",
                &InstructionsDebugHelper {
                    instructions: &self.instructions,
                },
            )
            .field("instruction_duration", &self.instruction_duration)
            .finish()
    }
}

/// Constructs an array of instructions for the given array.
pub const fn instructions<const N: usize, const INSTRUCTION_COUNT: usize>(
    instructions: [Instruction; N],
) -> [Instruction; INSTRUCTION_COUNT] {
    let mut cfg_instructions: [Instruction; INSTRUCTION_COUNT] =
        [Instruction::NoOp; INSTRUCTION_COUNT];

    if N > INSTRUCTION_COUNT {
        panic!("Too many instructions for instructions array");
    }

    let mut i = 0;

    while i < N {
        cfg_instructions[i] = instructions[i];
        i += 1;
    }

    cfg_instructions
}

/// Deserialize instructions.
fn deserialize_instructions<'de, D, const INSTRUCTION_COUNT: usize>(
    deserializer: D,
) -> Result<[Instruction; INSTRUCTION_COUNT], D::Error>
where
    D: serde::Deserializer<'de>,
{
    let instructions_vec: heapless::Vec<Instruction, INSTRUCTION_COUNT> =
        Deserialize::deserialize(deserializer)?;

    let mut instructions_array: [Instruction; INSTRUCTION_COUNT] =
        [Instruction::NoOp; INSTRUCTION_COUNT];
    for (i, instruction) in instructions_vec.iter().enumerate() {
        instructions_array[i] = *instruction;
    }

    Ok(instructions_array)
}

fn default_instruction_duration() -> u16 {
    DEFAULT_INSTRUCTION_DURATION
}

/// The default instruction duration.
pub const DEFAULT_INSTRUCTION_DURATION: u16 = 10;

impl<const INSTRUCTION_COUNT: usize> Config<INSTRUCTION_COUNT> {
    /// Constructs a new default [Config].
    pub const fn new() -> Self {
        Self {
            instructions: [{ Instruction::NoOp }; INSTRUCTION_COUNT],
            instruction_duration: DEFAULT_INSTRUCTION_DURATION,
        }
    }
}

impl<const INSTRUCTION_COUNT: usize> Default for Config<INSTRUCTION_COUNT> {
    fn default() -> Self {
        Self::new()
    }
}

struct ExecutionsDebugHelper<'a> {
    execution_queue: &'a [Execution; EXECUTION_QUEUE_SIZE],
}

impl core::fmt::Debug for ExecutionsDebugHelper<'_> {
    fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
        // Reverse-find the last non-empty execution to avoid printing large arrays.
        let last_non_empty_exec_pos = self
            .execution_queue
            .iter()
            .rposition(|exec| !exec.is_empty())
            .map_or(0, |pos| pos + 1);
        if last_non_empty_exec_pos < EXECUTION_QUEUE_SIZE {
            f.debug_list()
                .entries(&self.execution_queue[..last_non_empty_exec_pos])
                .finish_non_exhaustive()
        } else {
            f.debug_list().entries(&self.execution_queue[..]).finish()
        }
    }
}

/// Context for automation keys.
#[derive(Clone, Copy, PartialEq)]
pub struct Context<const INSTRUCTION_COUNT: usize> {
    config: Config<INSTRUCTION_COUNT>,
    execution_queue: [Execution; EXECUTION_QUEUE_SIZE],
}

impl<const INSTRUCTION_COUNT: usize> core::fmt::Debug for Context<INSTRUCTION_COUNT> {
    fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
        f.debug_struct("Context")
            .field("config", &self.config)
            .field(
                "execution_queue",
                &ExecutionsDebugHelper {
                    execution_queue: &self.execution_queue,
                },
            )
            .finish()
    }
}

impl<const INSTRUCTION_COUNT: usize> Context<INSTRUCTION_COUNT> {
    /// Constructs a new [Context] with the given [Config].
    pub const fn from_config(config: Config<INSTRUCTION_COUNT>) -> Self {
        let execution_queue = [Execution::EMPTY; EXECUTION_QUEUE_SIZE];
        Self {
            config,
            execution_queue,
        }
    }

    /// Re-construct from context's [Config], clearing the execution queue.
    pub fn reset(&mut self) {
        *self = Self::from_config(self.config);
    }

    /// Enqueues a new execution onto the execution queue.
    pub fn enqueue(&mut self, new_execution: Execution) -> usize {
        // Ignore empty executions.
        if new_execution.is_empty() {
            return EXECUTION_QUEUE_SIZE;
        }

        for (i, exec) in self.execution_queue.iter_mut().enumerate() {
            if exec.is_empty() {
                *exec = new_execution;
                return i;
            }
        }

        // Queue is full, drop the new execution.
        EXECUTION_QUEUE_SIZE
    }

    fn execute_head(&mut self, keymap_index: u16) -> key::KeyEvents<Event> {
        let mut pke = key_events_for(self.config, keymap_index, self.execution_queue[0]);

        self.execution_queue[0].incr();

        if self.execution_queue[0].is_empty() {
            self.execution_queue.rotate_left(1);
            self.execution_queue[EXECUTION_QUEUE_SIZE - 1] = Execution::EMPTY;

            // If there's more to execute, schedule it to execute.
            if !self.execution_queue[0].is_empty() {
                pke.add_event(key::ScheduledEvent::after(
                    self.config.instruction_duration,
                    key::Event::Key {
                        keymap_index,
                        key_event: Event::NextInstruction,
                    },
                ));
            }
        }

        pke
    }
}

impl<const INSTRUCTION_COUNT: usize> key::Context for Context<INSTRUCTION_COUNT> {
    type Event = Event;

    fn reset(&mut self) {
        Context::reset(self);
    }

    fn handle_event(&mut self, event: key::Event<Self::Event>) -> key::KeyEvents<Self::Event> {
        match event {
            key::Event::Key {
                key_event: Event::Enqueue(execution),
                keymap_index,
            } if !execution.is_empty() => {
                let exec_immediately = self.execution_queue[0].is_empty();

                self.enqueue(execution);

                if exec_immediately {
                    self.execute_head(keymap_index)
                } else {
                    key::KeyEvents::no_events()
                }
            }
            key::Event::Key {
                key_event: Event::NextInstruction,
                keymap_index,
            } => {
                if !self.execution_queue[0].is_empty() {
                    self.execute_head(keymap_index)
                } else {
                    key::KeyEvents::no_events()
                }
            }
            _ => key::KeyEvents::no_events(),
        }
    }
}

/// The event type for automation keys.
#[derive(Debug, Clone, Copy, PartialEq)]
pub enum Event {
    /// Enqueues an execution onto the Context's execution queue.
    Enqueue(Execution),
    /// Indicates to the context to execute the next instruction.
    NextInstruction,
    /// Indicates that the execution has finished.
    ExecutionFinished,
}

/// Converts the instruction to a scheduled event, if applicable.
pub fn key_events_for<const INSTRUCTION_COUNT: usize>(
    config: Config<INSTRUCTION_COUNT>,
    keymap_index: u16,
    Execution { start, length }: Execution,
) -> key::KeyEvents<Event> {
    let instruction = config.instructions[start as usize];

    let next_key_ev = if length > 1 {
        key::Event::Key {
            keymap_index,
            key_event: Event::NextInstruction,
        }
    } else {
        key::Event::Key {
            keymap_index,
            key_event: Event::ExecutionFinished,
        }
    };

    match instruction {
        Instruction::NoOp => {
            let sch_ev = key::ScheduledEvent::after(config.instruction_duration, next_key_ev);
            key::KeyEvents::scheduled_event(sch_ev)
        }
        Instruction::Press(key_output) => {
            let sch_ev =
                key::ScheduledEvent::immediate(key::Event::Input(input::Event::VirtualKeyPress {
                    key_output,
                }));

            let mut pke = key::KeyEvents::scheduled_event(sch_ev);
            let sch_ev = key::ScheduledEvent::after(config.instruction_duration, next_key_ev);
            pke.add_event(sch_ev);

            pke
        }
        Instruction::Release(key_output) => {
            let sch_ev = key::ScheduledEvent::immediate(key::Event::Input(
                input::Event::VirtualKeyRelease { key_output },
            ));

            let mut pke = key::KeyEvents::scheduled_event(sch_ev);
            let sch_ev = key::ScheduledEvent::after(config.instruction_duration, next_key_ev);
            pke.add_event(sch_ev);

            pke
        }
        Instruction::Tap(key_output) => {
            let sch_press_ev =
                key::ScheduledEvent::immediate(key::Event::Input(input::Event::VirtualKeyPress {
                    key_output,
                }));
            let sch_release_ev = key::ScheduledEvent::after(
                config.instruction_duration,
                key::Event::Input(input::Event::VirtualKeyRelease { key_output }),
            );

            let mut pke = key::KeyEvents::scheduled_event(sch_press_ev);
            pke.add_event(sch_release_ev);
            let sch_ev = key::ScheduledEvent::after(config.instruction_duration, next_key_ev);
            pke.add_event(sch_ev);

            pke
        }
        Instruction::Wait(ticks) => {
            let sch_ev = key::ScheduledEvent::after(ticks, next_key_ev);
            key::KeyEvents::scheduled_event(sch_ev)
        }
    }
}

/// The pending key state type for automation keys. (No pending state).
#[derive(Debug, Clone, Copy, PartialEq)]
pub struct PendingKeyState;

/// Key state used by [System].
#[derive(Debug, Clone, Copy, PartialEq)]
pub struct KeyState;

/// The [key::System] implementation for automation keys.
#[derive(Debug, Clone, Copy, PartialEq)]
pub struct System<R: Debug, Keys: Index<usize, Output = Key>, const INSTRUCTION_COUNT: usize> {
    keys: Keys,
    _marker: core::marker::PhantomData<(R, [(); INSTRUCTION_COUNT])>,
}

impl<R: Debug, Keys: Index<usize, Output = Key>, const INSTRUCTION_COUNT: usize>
    System<R, Keys, INSTRUCTION_COUNT>
{
    /// Constructs a new [System].
    pub const fn new(keys: Keys) -> Self {
        Self {
            keys,
            _marker: core::marker::PhantomData,
        }
    }
}

impl<R: Copy + Debug, Keys: Debug + Index<usize, Output = Key>, const INSTRUCTION_COUNT: usize>
    key::System<R> for System<R, Keys, INSTRUCTION_COUNT>
{
    type Ref = Ref;
    type Context = Context<INSTRUCTION_COUNT>;
    type Event = Event;
    type PendingKeyState = PendingKeyState;
    type KeyState = KeyState;

    fn new_pressed_key(
        &self,
        keymap_index: u16,
        _context: &Self::Context,
        Ref(key_index): Ref,
    ) -> (
        key::PressedKeyResult<R, Self::PendingKeyState, Self::KeyState>,
        key::KeyEvents<Self::Event>,
    ) {
        let pkr = key::PressedKeyResult::Resolved(KeyState);

        let Key {
            automation_instructions:
                KeyInstructions {
                    on_press: execution,
                    ..
                },
        } = self.keys[key_index as usize];
        let key_ev = key::Event::Key {
            keymap_index,
            key_event: if !execution.is_empty() {
                Event::Enqueue(execution)
            } else {
                // Trigger "while_pressed"
                Event::ExecutionFinished
            },
        };
        let pke = key::KeyEvents::event(key_ev);

        (pkr, pke)
    }

    fn update_pending_state(
        &self,
        _pending_state: &mut Self::PendingKeyState,
        _keymap_index: u16,
        _context: &Self::Context,
        _key_ref: Ref,
        _event: key::Event<Self::Event>,
    ) -> (Option<key::NewPressedKey<R>>, key::KeyEvents<Self::Event>) {
        panic!()
    }

    fn update_state(
        &self,
        _key_state: &mut Self::KeyState,
        Ref(key_index): &Self::Ref,
        _context: &Self::Context,
        keymap_index: u16,
        event: key::Event<Self::Event>,
    ) -> key::KeyEvents<Self::Event> {
        match event {
            key::Event::Key {
                key_event: Event::ExecutionFinished,
                keymap_index: ev_kmi,
            } if keymap_index == ev_kmi => {
                // Execution finished while key is pressed;
                //  enqueue the while_pressed instructions.
                let Key {
                    automation_instructions:
                        KeyInstructions {
                            while_pressed: execution,
                            ..
                        },
                } = self.keys[*key_index as usize];
                let key_ev = key::Event::Key {
                    keymap_index,
                    key_event: Event::Enqueue(execution),
                };
                key::KeyEvents::event(key_ev)
            }
            key::Event::Input(input::Event::Release {
                keymap_index: ev_kmi,
            }) if keymap_index == ev_kmi => {
                // Key released.
                //  enqueue the on_release instructions.
                let Key {
                    automation_instructions:
                        KeyInstructions {
                            on_release: execution,
                            ..
                        },
                } = self.keys[*key_index as usize];
                let key_ev = key::Event::Key {
                    keymap_index,
                    key_event: Event::Enqueue(execution),
                };
                key::KeyEvents::event(key_ev)
            }
            _ => key::KeyEvents::no_events(),
        }
    }

    fn key_output(
        &self,
        _key_ref: &Self::Ref,
        _key_state: &Self::KeyState,
    ) -> Option<key::KeyOutput> {
        None
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_sizeof_ref() {
        assert_eq!(1, core::mem::size_of::<Ref>());
    }

    #[test]
    fn test_sizeof_event() {
        assert_eq!(6, core::mem::size_of::<Event>());
    }
}