feat(Lua): add event scripting via Lua

Cargo.toml

@@ -39,6 +39,7 @@ log = { version = "0.4.22", features = [
   "release_max_level_debug",
 ] }
 mio = { version = "0.8.11", features = ["os-poll", "os-ext", "net"] }
+mlua = { version = "0.10.1", features = ["lua54", "vendored", "async", "send"] }
 nix = { version = "0.29.0", features = ["fs"] }
 packed_struct = "0.10.1"
 procfs = "0.16.0"

rootfs/usr/share/inputplumber/scripts/test.lua

@@ -0,0 +1,20 @@
+--print("---")
+
+-- process_event is called on every input event
+local process_event = function(event)
+	--print("Called process event!")
+	--print(event.capability)
+	--print(event.value)
+
+	if event.capability == "Gamepad:Button:Guide" then
+		print("Got guide button: ", event.value)
+	end
+
+	--for _, path in ipairs(source_device_paths) do
+	--	print(path)
+	--end
+end
+
+return {
+	process_event = process_event,
+}

src/input/capability.rs

@@ -23,6 +23,26 @@ pub enum Capability {
     Touchscreen(Touch),
 }
 
+impl Capability {
+    pub fn to_capability_string(&self) -> String {
+        match self {
+            Capability::Gamepad(gamepad) => match gamepad {
+                Gamepad::Button(button) => format!("Gamepad:Button:{}", button),
+                Gamepad::Axis(axis) => format!("Gamepad:Axis:{}", axis),
+                Gamepad::Trigger(trigger) => format!("Gamepad:Trigger:{}", trigger),
+                Gamepad::Accelerometer => "Gamepad:Accelerometer".to_string(),
+                Gamepad::Gyro => "Gamepad:Gyro".to_string(),
+            },
+            Capability::Mouse(mouse) => match mouse {
+                Mouse::Motion => "Mouse:Motion".to_string(),
+                Mouse::Button(button) => format!("Mouse:Button:{}", button),
+            },
+            Capability::Keyboard(key) => format!("Keyboard:{}", key),
+            _ => self.to_string(),
+        }
+    }
+}
+
 impl fmt::Display for Capability {
     fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
         match self {

src/input/composite_device/mod.rs

@@ -1,6 +1,8 @@
 pub mod client;
 pub mod command;
+pub mod script;
 
+use script::CompositeDeviceLua;
 use std::{
     borrow::Borrow,
     collections::{BTreeSet, HashMap, HashSet},
@@ -64,6 +66,8 @@ pub enum InterceptMode {
 pub struct CompositeDevice {
     /// Connection to DBus
     conn: Connection,
+    /// Lua state instance
+    lua: CompositeDeviceLua,
     /// Transmit channel to communicate with the input manager
     manager: mpsc::Sender<ManagerCommand>,
     /// Configuration for the CompositeDevice
@@ -164,6 +168,7 @@ impl CompositeDevice {
         let name = config.name.clone();
         let mut device = Self {
             conn,
+            lua: CompositeDeviceLua::new(tx.clone().into()),
             manager,
             config,
             name,
@@ -671,6 +676,9 @@ impl CompositeDevice {
             return Ok(());
         }
 
+        // Process the event with lua
+        self.lua.process_event(&event);
+
         // Check if the event needs to be translated based on the
         // capability map. Translated events will be re-enqueued, so this will
         // return early.
@@ -1368,6 +1376,8 @@ impl CompositeDevice {
 
         if let Some(idx) = self.source_device_paths.iter().position(|str| str == &path) {
             self.source_device_paths.remove(idx);
+            self.lua
+                .set_source_device_paths(self.source_device_paths.clone());
         };
 
         if let Some(idx) = self.source_devices_used.iter().position(|str| str == &id) {
@@ -1475,6 +1485,8 @@ impl CompositeDevice {
         let device_path = source_device.get_device_path();
         self.source_devices_discovered.push(source_device);
         self.source_device_paths.push(device_path);
+        self.lua
+            .set_source_device_paths(self.source_device_paths.clone());
         self.source_devices_used.push(id);
 
         Ok(())