.github/workflows/rust.yml

@@ -24,7 +24,7 @@ jobs:
       - name: Update repos
         run: sudo apt-get update -qq
       - name: Install rust toolchain
-        run: sudo apt-get install -qy cargo-1.80 rust-1.80-clippy
+        run: sudo apt-get install -qy cargo rust-clippy
       - name: Install system dependencies
         run: sudo apt-get install -qy liblzma-dev libfontconfig1-dev
 

Cargo.toml

@@ -1,16 +1,9 @@
 [package]
 name = "servicepoint-simulator"
-version = "0.2.3"
+version = "0.1.0"
 edition = "2021"
-publish = true
+publish = false
 license = "GPL-3.0-or-later"
-keywords = ["cccb", "cccb-servicepoint", "cli"]
-description = "A simulator for the Service Point display."
-homepage = "https://git.berlin.ccc.de/servicepoint/servicepoint-simulator"
-repository = "https://git.berlin.ccc.de/servicepoint/servicepoint-simulator.git"
-readme = "README.md"
-rust-version = "1.80.0"
-resolver = "2"
 
 [dependencies]
 # basics
@@ -20,7 +13,7 @@ clap = { version = "4.5", features = ["derive"] }
 thiserror = "2.0"
 
 # package parsing
-servicepoint = { features = ["all_compressions"], version = "0.15.2" }
+servicepoint = { version = "0.13.0", features = ["all_compressions"] }
 
 # font rendering
 font-kit = "0.14.2"
@@ -28,11 +21,6 @@ font-kit = "0.14.2"
 pathfinder_geometry = "0.5.1"
 
 # for opening a window
-winit = "0.30"
+winit = "0.30.8"
 # for drawing pixels onto the surface of the window
 softbuffer = "0.4.6"
-
-[profile.release]
-lto = true          # Enable link-time optimization
-codegen-units = 1   # Reduce number of codegen units to increase optimizations
-strip = true        # Strip symbols from binary

README.md

@@ -1,40 +1,25 @@
 # servicepoint-simulator
 
-[![Releases](https://git.berlin.ccc.de/servicepoint/servicepoint-simulator/badges/release.svg)](https://git.berlin.ccc.de/servicepoint/servicepoint-simulator/releases)
-[![crates.io](https://img.shields.io/crates/v/servicepoint-simulator.svg)](https://crates.io/crates/servicepoint-simulator)
-[![Crates.io Total Downloads](https://img.shields.io/crates/d/servicepoint-simulator)](https://crates.io/crates/servicepoint-simulator)
-[![GPLv3 licensed](https://img.shields.io/crates/l/servicepoint-simulator)](./LICENSE)
-[![CI](https://git.berlin.ccc.de/servicepoint/servicepoint-simulator/badges/workflows/rust.yml/badge.svg)](https://git.berlin.ccc.de/servicepoint/servicepoint-simulator)
-
-A simulator for the CCCB service point display.
+An emulator for the CCCB airport display. 
 
 ![example render](example_render.png)
 
-In CCCB, there is a big LED matrix screen you can send images to via UDP.
-This crate contains an application that can receive packages in the same binary format and display the contents to the
-user.
+In CCCB, there is a big LED matrix screen you can send images to via UDP. 
+This project aims to build a working an application that can receive packages in the same binary format and display the contents to the user.
 
 Use cases:
-
-- getting error messages for invalid packages (instead of nothing happening on the display)
+- getting error messages for invalid packages
 - test your project when outside CCCB
 - test your project while other people are using the display
 
 Uses the [servicepoint](https://github.com/cccb/servicepoint) library for reading the packets.
 The screenshot above shows the output of two example projects running in parallel (game_of_life and random_brightness).
 
-This repository moved
-to [git.berlin.ccc.de/servicepoint/servicepoint-simulator](https://git.berlin.ccc.de/servicepoint/servicepoint-simulator/).
-The [GitHub repository](https://github.com/kaesaecracker/servicepoint-simulator) will remain as a mirror.
-
 ## Running
 
-With cargo installed: `cargo install servicepoint-simulator`
-
 With nix flakes: `nix run github:kaesaecracker/servicepoint-simulator`
 
-You can also check out this repository and use `cargo run --release`.
-Make sure to run a release build, because a debug build _way_ slower.
+Without nix: check out this repository and use `cargo run --release`.
 
 ## Command line arguments
 
@@ -54,19 +39,11 @@ Options:
 
 See [env_logger](https://docs.rs/env_logger/latest/env_logger/) to configure logging.
 
-Because this program renders to an RGB pixel buffer, you can enjoy the following additional features not available on
-the real display:
+Because this program renders to an RGB pixel buffer, you can enjoy the following additional features not available on the real display:
 
 - enable or disable the empty space between tile rows (`./servicepoint-simulator --spacers` to enable)
 - render pixels in red, green, blue or a combination of the three (`./servicepoint-simulator -rgb` for white pixels)
 
-## Known differences
-
-- The font used for displaying UTF-8 text is your default system monospace font, rendered to 8x8 pixels
-- The brightness levels will look linear in the simulator
-- Some commands will be executed in part on the real display and then produce an error (in a console you cannot see)
-  while the simulator refuses to execute the whole command
-
 ## Contributing
 
 Contributions are accepted in any form (issues, documentation, feature requests, code, reviews, ...).
@@ -75,7 +52,6 @@ All creatures welcome.
 
 ## Legal stuff
 
-The included font is https://int10h.org/oldschool-pc-fonts/fontlist/font?ibm_bios (included in the download
-from https://int10h.org/oldschool-pc-fonts/download/). The font is CC BY-SA 4.0.
+The included font is https://int10h.org/oldschool-pc-fonts/fontlist/font?ibm_bios (included in the download from https://int10h.org/oldschool-pc-fonts/download/). The font is CC BY-SA 4.0.
 
 For everything else see the LICENSE file.

flake.lock

@@ -7,11 +7,11 @@
         ]
       },
       "locked": {
-        "lastModified": 1745925850,
-        "narHash": "sha256-cyAAMal0aPrlb1NgzMxZqeN1mAJ2pJseDhm2m6Um8T0=",
+        "lastModified": 1736429655,
+        "narHash": "sha256-BwMekRuVlSB9C0QgwKMICiJ5EVbLGjfe4qyueyNQyGI=",
         "owner": "nix-community",
         "repo": "naersk",
-        "rev": "38bc60bbc157ae266d4a0c96671c6c742ee17a5f",
+        "rev": "0621e47bd95542b8e1ce2ee2d65d6a1f887a13ce",
         "type": "github"
       },
       "original": {
@@ -37,16 +37,16 @@
     },
     "nixpkgs": {
       "locked": {
-        "lastModified": 1750969886,
-        "narHash": "sha256-zW/OFnotiz/ndPFdebpo3X0CrbVNf22n4DjN2vxlb58=",
+        "lastModified": 1736200483,
+        "narHash": "sha256-JO+lFN2HsCwSLMUWXHeOad6QUxOuwe9UOAF/iSl1J4I=",
         "owner": "nixos",
         "repo": "nixpkgs",
-        "rev": "a676066377a2fe7457369dd37c31fd2263b662f4",
+        "rev": "3f0a8ac25fb674611b98089ca3a5dd6480175751",
         "type": "github"
       },
       "original": {
         "owner": "nixos",
-        "ref": "nixos-25.05",
+        "ref": "nixos-24.11",
         "repo": "nixpkgs",
         "type": "github"
       }

flake.nix

@@ -2,7 +2,7 @@
   description = "Flake for servicepoint-simulator";
 
   inputs = {
-    nixpkgs.url = "github:nixos/nixpkgs/nixos-25.05";
+    nixpkgs.url = "github:nixos/nixpkgs/nixos-24.11";
     nix-filter.url = "github:numtide/nix-filter";
     naersk = {
       url = "github:nix-community/naersk";

src/command_executor.rs

@@ -1,22 +1,16 @@
-use crate::{
-    command_executor::ExecutionResult::{Failure, Shutdown, Success},
-    cp437_font::Cp437Font,
-    font_renderer::FontRenderer8x8,
-};
+use crate::command_executor::ExecutionResult::{Failure, Shutdown, Success};
+use crate::cp437_font::Cp437Font;
+use crate::font_renderer::FontRenderer8x8;
 use log::{debug, error, info, trace, warn};
 use servicepoint::{
-    BinaryOperation, BitVecCommand, Bitmap, BitmapCommand, GlobalBrightnessCommand,
-    BrightnessGrid, BrightnessGridCommand, CharGridCommand, ClearCommand,
-    CompressionCode, Cp437GridCommand, FadeOutCommand, Grid, HardResetCommand,
-    Origin, TypedCommand, PIXEL_COUNT, PIXEL_WIDTH, TILE_SIZE,
-};
-use std::{
-    ops::{BitAnd, BitOr, BitXor},
-    sync::RwLock,
+    BitVec, Bitmap, BrightnessGrid, CharGrid, Command, Cp437Grid, Grid, Offset,
+    Origin, Tiles, PIXEL_COUNT, PIXEL_WIDTH, TILE_SIZE,
 };
+use std::ops::{BitAnd, BitOr, BitXor};
+use std::sync::RwLock;
 
 #[derive(Debug)]
-pub struct CommandExecutionContext<'t> {
+pub struct CommandExecutor<'t> {
     display: &'t RwLock<Bitmap>,
     luma: &'t RwLock<BrightnessGrid>,
     cp437_font: Cp437Font,
@@ -30,36 +24,201 @@ pub enum ExecutionResult {
     Shutdown,
 }
 
-pub trait CommandExecute {
-    fn execute(&self, context: &CommandExecutionContext) -> ExecutionResult;
-}
+impl<'t> CommandExecutor<'t> {
+    pub fn new(
+        display: &'t RwLock<Bitmap>,
+        luma: &'t RwLock<BrightnessGrid>,
+        font_renderer: FontRenderer8x8,
+    ) -> Self {
+        CommandExecutor {
+            display,
+            luma,
+            font_renderer,
+            cp437_font: Cp437Font::default(),
+        }
+    }
 
-impl CommandExecute for ClearCommand {
-    fn execute(&self, context: &CommandExecutionContext) -> ExecutionResult {
-        info!("clearing display");
-        context.display.write().unwrap().fill(false);
+    pub(crate) fn execute(&self, command: Command) -> ExecutionResult {
+        debug!("received {command:?}");
+        match command {
+            Command::Clear => {
+                info!("clearing display");
+                self.display.write().unwrap().fill(false);
+                Success
+            }
+            Command::HardReset => {
+                warn!("display shutting down");
+                Shutdown
+            }
+            Command::BitmapLinearWin(Origin { x, y, .. }, pixels, _) => {
+                self.print_pixel_grid(x, y, &pixels)
+            }
+            Command::Cp437Data(origin, grid) => {
+                self.print_cp437_data(origin, &grid)
+            }
+            #[allow(deprecated)]
+            Command::BitmapLegacy => {
+                warn!("ignoring deprecated command {:?}", command);
+                Failure
+            }
+            Command::BitmapLinearAnd(offset, vec, _) => {
+                self.execute_bitmap_linear(offset, vec, BitAnd::bitand)
+            }
+            Command::BitmapLinearOr(offset, vec, _) => {
+                self.execute_bitmap_linear(offset, vec, BitOr::bitor)
+            }
+            Command::BitmapLinearXor(offset, vec, _) => {
+                self.execute_bitmap_linear(offset, vec, BitXor::bitxor)
+            }
+            Command::BitmapLinear(offset, vec, _) => {
+                self.execute_bitmap_linear(offset, vec, move |_, new| new)
+            }
+            Command::CharBrightness(origin, grid) => {
+                self.execute_char_brightness(origin, grid)
+            }
+            Command::Brightness(brightness) => {
+                self.luma.write().unwrap().fill(brightness);
+                Success
+            }
+            Command::FadeOut => {
+                error!("command not implemented: {command:?}");
+                Success
+            }
+            Command::Utf8Data(origin, grid) => {
+                self.print_utf8_data(origin, &grid)
+            }
+        }
+    }
+
+    fn execute_char_brightness(
+        &self,
+        origin: Origin<Tiles>,
+        grid: BrightnessGrid,
+    ) -> ExecutionResult {
+        let mut luma = self.luma.write().unwrap();
+        for inner_y in 0..grid.height() {
+            for inner_x in 0..grid.width() {
+                let brightness = grid.get(inner_x, inner_y);
+                luma.set(origin.x + inner_x, origin.y + inner_y, brightness);
+            }
+        }
         Success
     }
-}
 
-impl CommandExecute for BitmapCommand {
-    fn execute(&self, context: &CommandExecutionContext) -> ExecutionResult {
-        let Self {
-            origin:
-            Origin {
-                x: offset_x,
-                y: offset_y,
-                ..
-            },
-            bitmap: pixels,
-            ..
-        } = self;
+    fn execute_bitmap_linear<Op>(
+        &self,
+        offset: Offset,
+        vec: BitVec,
+        op: Op,
+    ) -> ExecutionResult
+    where
+        Op: Fn(bool, bool) -> bool,
+    {
+        if !Self::check_bitmap_valid(offset as u16, vec.len()) {
+            return Failure;
+        }
+        let mut display = self.display.write().unwrap();
+        for bitmap_index in 0..vec.len() {
+            let (x, y) = Self::get_coordinates_for_index(offset, bitmap_index);
+            let old_value = display.get(x, y);
+            display.set(x, y, op(old_value, vec[bitmap_index]));
+        }
+        Success
+    }
+
+    fn check_bitmap_valid(offset: u16, payload_len: usize) -> bool {
+        if offset as usize + payload_len > PIXEL_COUNT {
+            error!(
+                "bitmap with offset {offset} is too big ({payload_len} bytes)"
+            );
+            return false;
+        }
+
+        true
+    }
+
+    fn print_cp437_data(
+        &self,
+        origin: Origin<Tiles>,
+        grid: &Cp437Grid,
+    ) -> ExecutionResult {
+        let font = &self.cp437_font;
+        let Origin { x, y, .. } = origin;
+        for char_y in 0usize..grid.height() {
+            for char_x in 0usize..grid.width() {
+                let char_code = grid.get(char_x, char_y);
+                trace!(
+                "drawing char_code {char_code:#04x} (if this was UTF-8, it would be {})",
+                char::from(char_code)
+            );
+
+                let tile_x = char_x + x;
+                let tile_y = char_y + y;
+
+                match self.print_pixel_grid(
+                    tile_x * TILE_SIZE,
+                    tile_y * TILE_SIZE,
+                    &font[char_code],
+                ) {
+                    Success => {}
+                    Failure => {
+                        error!(
+                            "stopping drawing text because char draw failed"
+                        );
+                        return Failure;
+                    }
+                    Shutdown => return Shutdown,
+                }
+            }
+        }
+
+        Success
+    }
+
+    fn print_utf8_data(
+        &self,
+        origin: Origin<Tiles>,
+        grid: &CharGrid,
+    ) -> ExecutionResult {
+        let mut display = self.display.write().unwrap();
+
+        let Origin { x, y, .. } = origin;
+        for char_y in 0usize..grid.height() {
+            for char_x in 0usize..grid.width() {
+                let char = grid.get(char_x, char_y);
+                trace!("drawing {char}");
+
+                let tile_x = char_x + x;
+                let tile_y = char_y + y;
+
+                if let Err(e) = self.font_renderer.render(
+                    char,
+                    &mut display,
+                    Origin::new(tile_x * TILE_SIZE, tile_y * TILE_SIZE),
+                ) {
+                    error!(
+                        "stopping drawing text because char draw failed: {e}"
+                    );
+                    return Failure;
+                }
+            }
+        }
+
+        Success
+    }
+
+    fn print_pixel_grid(
+        &self,
+        offset_x: usize,
+        offset_y: usize,
+        pixels: &Bitmap,
+    ) -> ExecutionResult {
         debug!(
             "printing {}x{} grid at {offset_x} {offset_y}",
             pixels.width(),
             pixels.height()
         );
-        let mut display = context.display.write().unwrap();
+        let mut display = self.display.write().unwrap();
         for inner_y in 0..pixels.height() {
             for inner_x in 0..pixels.width() {
                 let is_set = pixels.get(inner_x, inner_y);
@@ -77,186 +236,12 @@ impl CommandExecute for BitmapCommand {
 
         Success
     }
-}
 
-impl CommandExecute for HardResetCommand {
-    fn execute(&self, _: &CommandExecutionContext) -> ExecutionResult {
-        warn!("display shutting down");
-        Shutdown
-    }
-}
-
-impl CommandExecute for BitVecCommand {
-    fn execute(&self, context: &CommandExecutionContext) -> ExecutionResult {
-        let BitVecCommand {
-            offset,
-            bitvec,
-            operation,
-            ..
-        } = self;
-        fn overwrite(_: bool, new: bool) -> bool {
-            new
-        }
-        let operation = match operation {
-            BinaryOperation::Overwrite => overwrite,
-            BinaryOperation::And => BitAnd::bitand,
-            BinaryOperation::Or => BitOr::bitor,
-            BinaryOperation::Xor => BitXor::bitxor,
-        };
-
-        if self.offset + bitvec.len() > PIXEL_COUNT {
-            error!(
-                "bitmap with offset {offset} is too big ({} bytes)",
-                bitvec.len()
-            );
-            return Failure;
-        }
-
-        let mut display = context.display.write().unwrap();
-        for bitmap_index in 0..bitvec.len() {
-            let pixel_index = offset + bitmap_index;
-            let (x, y) = (pixel_index % PIXEL_WIDTH, pixel_index / PIXEL_WIDTH);
-            let old_value = display.get(x, y);
-            display.set(x, y, operation(old_value, bitvec[bitmap_index]));
-        }
-        Success
-    }
-}
-
-impl CommandExecute for Cp437GridCommand {
-    fn execute(&self, context: &CommandExecutionContext) -> ExecutionResult {
-        let Cp437GridCommand { origin, grid } = self;
-        let Origin { x, y, .. } = origin;
-        for char_y in 0usize..grid.height() {
-            for char_x in 0usize..grid.width() {
-                let char_code = grid.get(char_x, char_y);
-                trace!(
-                "drawing char_code {char_code:#04x} (if this was UTF-8, it would be {})",
-                char::from(char_code)
-            );
-
-                let tile_x = char_x + x;
-                let tile_y = char_y + y;
-
-                let execute_result = BitmapCommand {
-                    origin: Origin::new(tile_x * TILE_SIZE, tile_y * TILE_SIZE),
-                    bitmap: context.cp437_font[char_code].clone(),
-                    compression: CompressionCode::default(),
-                }
-                    .execute(context);
-                match execute_result {
-                    Success => {}
-                    Failure => {
-                        error!(
-                            "stopping drawing text because char draw failed"
-                        );
-                        return Failure;
-                    }
-                    Shutdown => return Shutdown,
-                }
-            }
-        }
-
-        Success
-    }
-}
-
-#[allow(deprecated)]
-impl CommandExecute for servicepoint::BitmapLegacyCommand {
-    fn execute(&self, _: &CommandExecutionContext) -> ExecutionResult {
-        warn!("ignoring deprecated command {:?}", self);
-        Failure
-    }
-}
-
-impl CommandExecute for BrightnessGridCommand {
-    fn execute(&self, context: &CommandExecutionContext) -> ExecutionResult {
-        let BrightnessGridCommand { origin, grid } = self;
-        let mut luma = context.luma.write().unwrap();
-        for inner_y in 0..grid.height() {
-            for inner_x in 0..grid.width() {
-                let brightness = grid.get(inner_x, inner_y);
-                luma.set(origin.x + inner_x, origin.y + inner_y, brightness);
-            }
-        }
-        Success
-    }
-}
-
-impl CommandExecute for CharGridCommand {
-    fn execute(&self, context: &CommandExecutionContext) -> ExecutionResult {
-        let CharGridCommand { origin, grid } = self;
-        let mut display = context.display.write().unwrap();
-
-        let Origin { x, y, .. } = origin;
-        for char_y in 0usize..grid.height() {
-            for char_x in 0usize..grid.width() {
-                let char = grid.get(char_x, char_y);
-                trace!("drawing {char}");
-
-                let tile_x = char_x + x;
-                let tile_y = char_y + y;
-
-                if let Err(e) = context.font_renderer.render(
-                    char,
-                    &mut display,
-                    Origin::new(tile_x * TILE_SIZE, tile_y * TILE_SIZE),
-                ) {
-                    error!(
-                        "stopping drawing text because char draw failed: {e}"
-                    );
-                    return Failure;
-                }
-            }
-        }
-
-        Success
-    }
-}
-
-impl CommandExecute for GlobalBrightnessCommand {
-    fn execute(&self, context: &CommandExecutionContext) -> ExecutionResult {
-        context.luma.write().unwrap().fill(self.brightness);
-        Success
-    }
-}
-
-impl CommandExecute for FadeOutCommand {
-    fn execute(&self, _: &CommandExecutionContext) -> ExecutionResult {
-        error!("command not implemented: {self:?}");
-        Success
-    }
-}
-
-impl CommandExecute for TypedCommand {
-    fn execute(&self, context: &CommandExecutionContext) -> ExecutionResult {
-        match self {
-            TypedCommand::Clear(command) => command.execute(context),
-            TypedCommand::HardReset(command) => command.execute(context),
-            TypedCommand::Bitmap(command) => command.execute(context),
-            TypedCommand::Cp437Grid(command) => command.execute(context),
-            #[allow(deprecated)]
-            TypedCommand::BitmapLegacy(command) => command.execute(context),
-            TypedCommand::BitVec(command) => command.execute(context),
-            TypedCommand::BrightnessGrid(command) => command.execute(context),
-            TypedCommand::Brightness(command) => command.execute(context),
-            TypedCommand::FadeOut(command) => command.execute(context),
-            TypedCommand::CharGrid(command) => command.execute(context),
-        }
-    }
-}
-
-impl<'t> CommandExecutionContext<'t> {
-    pub fn new(
-        display: &'t RwLock<Bitmap>,
-        luma: &'t RwLock<BrightnessGrid>,
-        font_renderer: FontRenderer8x8,
-    ) -> Self {
-        CommandExecutionContext {
-            display,
-            luma,
-            font_renderer,
-            cp437_font: Cp437Font::default(),
-        }
+    fn get_coordinates_for_index(
+        offset: usize,
+        index: usize,
+    ) -> (usize, usize) {
+        let pixel_index = offset + index;
+        (pixel_index % PIXEL_WIDTH, pixel_index / PIXEL_WIDTH)
     }
 }

src/cp437_font.rs

@@ -16,9 +16,8 @@ impl Cp437Font {
 
 impl Default for Cp437Font {
     fn default() -> Self {
-        let mut bitmaps = core::array::from_fn(|_| {
-            Bitmap::new(TILE_SIZE, TILE_SIZE).unwrap()
-        });
+        let mut bitmaps =
+            core::array::from_fn(|_| Bitmap::new(TILE_SIZE, TILE_SIZE));
 
         for (char_code, bitmap) in bitmaps.iter_mut().enumerate() {
             let bits = CP437_FONT_LINEAR[char_code];

src/font_renderer.rs

@@ -102,8 +102,8 @@ impl FontRenderer8x8 {
         for y in 0..TILE_SIZE {
             for x in 0..TILE_SIZE {
                 let canvas_val = canvas.pixels[x + y * TILE_SIZE] != 0;
-                let bitmap_x = offset.x + x;
-                let bitmap_y = offset.y + y;
+                let bitmap_x = (offset.x + x) as isize;
+                let bitmap_y = (offset.y + y) as isize;
                 if !bitmap.set_optional(bitmap_x, bitmap_y, canvas_val) {
                     return Err(OutOfBounds(x, y));
                 }

src/gui.rs

@@ -1,6 +1,7 @@
+use std::{sync::mpsc::Sender, sync::RwLock};
+
 use log::{info, warn};
 use servicepoint::*;
-use std::{sync::mpsc::Sender, sync::RwLock};
 use winit::{
     application::ApplicationHandler, dpi::LogicalSize, event::WindowEvent,
     event_loop::ActiveEventLoop, keyboard::KeyCode::KeyC, window::WindowId,

src/main.rs

@@ -2,7 +2,7 @@
 
 use crate::font_renderer::FontRenderer8x8;
 use crate::udp_server::UdpServer;
-use crate::{command_executor::CommandExecutionContext, gui::Gui};
+use crate::{command_executor::CommandExecutor, gui::Gui};
 use clap::Parser;
 use cli::Cli;
 use log::{info, LevelFilter};
@@ -32,18 +32,18 @@ fn main() {
         .expect("could not create event loop");
     event_loop.set_control_flow(ControlFlow::Wait);
 
-    let display = RwLock::new(Bitmap::max_sized());
+    let display = RwLock::new(Bitmap::new(PIXEL_WIDTH, PIXEL_HEIGHT));
     let luma = RwLock::new(BrightnessGrid::new(TILE_WIDTH, TILE_HEIGHT));
     let (stop_udp_tx, stop_udp_rx) = mpsc::channel();
     let font_renderer = cli
         .font
         .map(FontRenderer8x8::from_name)
         .unwrap_or_else(FontRenderer8x8::default);
-    let context = CommandExecutionContext::new(&display, &luma, font_renderer);
+    let command_executor = CommandExecutor::new(&display, &luma, font_renderer);
     let mut udp_server = UdpServer::new(
         cli.bind,
         stop_udp_rx,
-        context,
+        command_executor,
         event_loop.create_proxy(),
     );
     let mut gui = Gui::new(&display, &luma, stop_udp_tx, cli.gui);

src/udp_server.rs

@@ -1,22 +1,20 @@
-use crate::command_executor::CommandExecute;
-use crate::{
-    command_executor::{CommandExecutionContext, ExecutionResult},
-    gui::AppEvents,
-};
-use log::{debug, error, warn};
-use servicepoint::TypedCommand;
-use std::{
-    io::ErrorKind, net::UdpSocket, sync::mpsc::Receiver, time::Duration,
-};
+use crate::command_executor::{CommandExecutor, ExecutionResult};
+use crate::gui::AppEvents;
+use log::{error, warn};
+use servicepoint::Command;
+use std::io::ErrorKind;
+use std::net::UdpSocket;
+use std::sync::mpsc::Receiver;
+use std::time::Duration;
 use winit::event_loop::EventLoopProxy;
 
-const BUF_SIZE: usize = 8985 * 2;
+const BUF_SIZE: usize = 8985;
 
 #[derive(Debug)]
 pub struct UdpServer<'t> {
     socket: UdpSocket,
     stop_rx: Receiver<()>,
-    command_executor: CommandExecutionContext<'t>,
+    command_executor: CommandExecutor<'t>,
     app_events: EventLoopProxy<AppEvents>,
     buf: [u8; BUF_SIZE],
 }
@@ -25,7 +23,7 @@ impl<'t> UdpServer<'t> {
     pub fn new(
         bind: String,
         stop_rx: Receiver<()>,
-        command_executor: CommandExecutionContext<'t>,
+        command_executor: CommandExecutor<'t>,
         app_events: EventLoopProxy<AppEvents>,
     ) -> Self {
         let socket = UdpSocket::bind(bind).expect("could not bind socket");
@@ -47,8 +45,7 @@ impl<'t> UdpServer<'t> {
             if let Some(cmd) = self.receive_into_buf().and_then(|amount| {
                 Self::command_from_slice(&self.buf[..amount])
             }) {
-                debug!("received {cmd:?}");
-                match cmd.execute(&self.command_executor) {
+                match self.command_executor.execute(cmd) {
                     ExecutionResult::Success => {
                         self.app_events
                             .send_event(AppEvents::UdpPacketHandled)
@@ -68,13 +65,13 @@ impl<'t> UdpServer<'t> {
         }
     }
 
-    fn command_from_slice(slice: &[u8]) -> Option<TypedCommand> {
+    fn command_from_slice(slice: &[u8]) -> Option<Command> {
         let packet = servicepoint::Packet::try_from(slice)
             .inspect_err(|_| {
                 warn!("could not load packet with length {}", slice.len())
             })
             .ok()?;
-        TypedCommand::try_from(packet)
+        Command::try_from(packet)
             .inspect_err(move |err| {
                 warn!("could not read command for packet: {:?}", err)
             })